From 472a750311e21391e929665562815a1e89e75cab Mon Sep 17 00:00:00 2001 From: Michael Jeffrey Date: Thu, 12 Dec 2024 13:23:23 -0700 Subject: [PATCH] Add some logs to processing unique connections --- mobile_verifier/src/unique_connections/ingestor.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/mobile_verifier/src/unique_connections/ingestor.rs b/mobile_verifier/src/unique_connections/ingestor.rs index 36a599c04..eb32198e5 100644 --- a/mobile_verifier/src/unique_connections/ingestor.rs +++ b/mobile_verifier/src/unique_connections/ingestor.rs @@ -128,6 +128,9 @@ where &self, file_info_stream: FileInfoStream, ) -> 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?; @@ -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(()) }