Improvements to the transaction list (#12085)

1 files changed, 8 insertions, 1 deletions

diff --git a/ydb/core/persqueue/pq_impl_app.cpp b/ydb/core/persqueue/pq_impl_app.cpp
index 331c13339e..f439a67111 100644
--- a/ydb/core/persqueue/pq_impl_app.cpp
+++ b/ydb/core/persqueue/pq_impl_app.cpp
@@ -123,7 +123,7 @@ private:
                                                     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 @@ private:
         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);
     }