From 98be36ff224f905888aadaed3224c412c361c66e Mon Sep 17 00:00:00 2001
From: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Date: Thu, 4 Jan 2024 11:36:05 +0100
Subject: [PATCH] wire operator name to more logging places

---
 src/persist-txn/src/operator.rs | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/persist-txn/src/operator.rs b/src/persist-txn/src/operator.rs
index 3813109b1ee66..af9382478419b 100644
--- a/src/persist-txn/src/operator.rs
+++ b/src/persist-txn/src/operator.rs
@@ -234,8 +234,15 @@ where
         let [mut cap]: [_; 1] = capabilities.try_into().expect("one capability per output");
         let client = client.await;
         let state = TxnsCacheState::new(txns_id, T::minimum(), Some(data_id));
+        let cache_name = format!(
+            "{} {:.9} {}/{}",
+            name,
+            data_id.to_string(),
+            worker_idx,
+            num_workers
+        );
         let mut txns_cache = TxnsCacheTimely {
-            name: name.clone(),
+            name: cache_name,
             state,
             input: txns_input,
             buf: Vec::new(),
@@ -460,7 +467,8 @@ where
             }
         }
         debug!(
-            "cache correct before {:?} len={} least_ts={:?}",
+            "{} cache correct before {:?} len={} least_ts={:?}",
+            self.name,
             self.state.progress_exclusive,
             self.state.unapplied_batches.len(),
             self.state