mirror of
https://github.com/catdevnull/preciazo.git
synced 2024-11-26 03:26:19 +00:00
warcificator: limpiar
This commit is contained in:
parent
2d2912e4e9
commit
56a257c389
1 changed files with 2 additions and 2 deletions
|
@ -185,7 +185,7 @@ async fn worker(rx: Receiver<String>, tx: Sender<PrecioPoint>) {
|
||||||
}
|
}
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
stderr()
|
stderr()
|
||||||
.write_all(format!("Failed to fetch {}: {:#?}\n", url.as_str(), err).as_bytes())
|
.write_all(format!("Failed to fetch {}: {:?}\n", url.as_str(), err).as_bytes())
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
@ -355,7 +355,7 @@ fn now_sec() -> u64 {
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn db_writer(rx: Receiver<PrecioPoint>) {
|
async fn db_writer(rx: Receiver<PrecioPoint>) {
|
||||||
let conn = Connection::open("../scraper/sqlite.db").unwrap();
|
// let conn = Connection::open("../scraper/sqlite.db").unwrap();
|
||||||
// let mut stmt = conn.prepare("SELECT id, name, data FROM person")?;
|
// let mut stmt = conn.prepare("SELECT id, name, data FROM person")?;
|
||||||
while let Ok(res) = rx.recv().await {
|
while let Ok(res) = rx.recv().await {
|
||||||
println!("{:?}", res)
|
println!("{:?}", res)
|
||||||
|
|
Loading…
Reference in a new issue