[*] Step value

ydb-platform · Nov 28, 2024 · 14f363c · 14f363c
1 parent 3891cbb
commit 14f363c
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/ydb/core/persqueue/pq_impl_app.cpp b/ydb/core/persqueue/pq_impl_app.cpp
@@ -123,7 +123,7 @@ class TMonitoringProxy : public TActorBootstrapped<TMonitoringProxy> {
                                                     str << tx.TxId;
                                                 }
                                             }
-                                            TABLED() {str << tx.Step;}
+                                            TABLED() {str << GetTxStep(tx);}
                                             TABLED() {str << NKikimrPQ::TTransaction_EState_Name(tx.State);}
                                             TABLED() {str << tx.MinStep;}
                                             TABLED() {str << tx.MaxStep;}
@@ -147,6 +147,13 @@ class TMonitoringProxy : public TActorBootstrapped<TMonitoringProxy> {
         Die(ctx);
     }
 
+    static TString GetTxStep(const TTransactionSnapshot& tx) {
+        if (tx.Step == Max<ui64>()) {
+            return "-";
+        }
+        return ToString(tx.Step);
+    }
+
     void Wakeup(const TActorContext& ctx) {
         Reply(ctx);
     }