Skip to content

Commit

Permalink
Fix logs statements & dependencies
Browse files Browse the repository at this point in the history
  • Loading branch information
Wiezzel committed Jul 30, 2024
1 parent e118679 commit 14023ab
Show file tree
Hide file tree
Showing 5 changed files with 13 additions and 12 deletions.
12 changes: 6 additions & 6 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,6 @@ members = ["crates/*"]
resolver = "2"

[workspace.dependencies]
contract-client = { git = "https://github.com/subsquid/subsquid-network.git", rev = "8df33fe" }
subsquid-messages = { git = "https://github.com/subsquid/subsquid-network.git", rev = "8df33fe" }
subsquid-network-transport = { git = "https://github.com/subsquid/subsquid-network.git", rev = "8df33fe" }
contract-client = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.3" }
subsquid-messages = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.1" }
subsquid-network-transport = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.7" }
2 changes: 1 addition & 1 deletion crates/collector-utils/src/storage.rs
Original file line number Diff line number Diff line change
Expand Up @@ -275,7 +275,7 @@ impl Storage for ClickhouseStorage {
log::debug!("Storing pings in clickhouse");
let mut insert = self.0.insert(&PINGS_TABLE)?;
for row in pings {
println!("Storing ping {:?}", row);
log::trace!("Storing ping {:?}", row);
insert.write(&row).await?;
}
insert.end().await?;
Expand Down
2 changes: 1 addition & 1 deletion crates/pings-collector/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "pings-collector"
version = "1.0.0"
version = "1.0.1"
edition = "2021"

[dependencies]
Expand Down
3 changes: 2 additions & 1 deletion crates/pings-collector/src/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -178,7 +178,7 @@ impl<S: Storage + Send + Sync + 'static> StorageWriter<S> {
}
}
};
log::debug!("Read {} ping rows from buffer", recv_guard.len());
log::info!("Read {} ping rows from buffer", recv_guard.len());
let ping_rows =
recv_guard.iter().filter_map(|b| {
match bincode::serde::decode_from_slice(b, *BINCODE_CONFIG) {
Expand All @@ -191,6 +191,7 @@ impl<S: Storage + Send + Sync + 'static> StorageWriter<S> {
});
match self.storage.store_pings(ping_rows).await {
Ok(()) => {
log::info!("Pings stored successfully");
_ = recv_guard.commit().map_err(|e| log::error!("{e:?}"));
}
Err(e) => {
Expand Down

0 comments on commit 14023ab

Please sign in to comment.