Skip to content

Commit

Permalink
Add some logs to processing unique connections
Browse files Browse the repository at this point in the history
  • Loading branch information
michaeldjeffrey committed Dec 12, 2024
1 parent f82f617 commit 472a750
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions mobile_verifier/src/unique_connections/ingestor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -128,6 +128,9 @@ where
&self,
file_info_stream: FileInfoStream<UniqueConnectionsIngestReport>,
) -> anyhow::Result<()> {
let file_info = file_info_stream.file_info.clone();
tracing::info!(?file_info, "processing file");

let mut txn = self.pool.begin().await?;
let mut stream = file_info_stream.into_stream(&mut txn).await?;

Expand Down Expand Up @@ -162,6 +165,7 @@ where
db::save(&mut txn, &verified).await?;
txn.commit().await?;
self.verified_unique_connections_sink.commit().await?;
tracing::info!(?file_info, "txn and sink committed");

Ok(())
}
Expand Down

0 comments on commit 472a750

Please sign in to comment.