core: better logging of upserts steps (#8282)

dust-tt · Oct 28, 2024 · b11327b · b11327b
1 parent 8ade0e2
commit b11327b
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/core/src/databases/table.rs b/core/src/databases/table.rs
@@ -266,7 +266,8 @@ impl LocalTable {
         }
         info!(
             duration = utils::now() - now,
-            "DSSTRUCTSTAT Upsert rows validation"
+            table_id = self.table.table_id(),
+            "DSSTRUCTSTAT [upsert_rows] validation"
         );
 
         now = utils::now();
@@ -285,6 +286,7 @@ impl LocalTable {
         };
         info!(
             duration = utils::now() - now,
+            table_id = self.table.table_id(),
             "DSSTRUCTSTAT [upsert_rows] table schema"
         );
 
@@ -299,6 +301,7 @@ impl LocalTable {
             .await?;
         info!(
             duration = utils::now() - now,
+            table_id = self.table.table_id(),
             "DSSTRUCTSTAT [upsert_rows] update table_schema"
         );
 
@@ -321,6 +324,7 @@ impl LocalTable {
         }
         info!(
             duration = utils::now() - now,
+            table_id = self.table.table_id(),
             "DSSTRUCTSTAT [upsert_rows] invalidate table schema"
         );
 
@@ -335,6 +339,7 @@ impl LocalTable {
             .await?;
         info!(
             duration = utils::now() - now,
+            table_id = self.table.table_id(),
             "DSSTRUCTSTAT [upsert_rows] rows upsert"
         );
 
@@ -361,6 +366,7 @@ impl LocalTable {
         .await?;
         info!(
             duration = utils::now() - now,
+            table_id = self.table.table_id(),
             "DSSTRUCTSTAT [upsert_rows] invalidate dbs"
         );