We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7680faa commit a02f6d5Copy full SHA for a02f6d5
ydb/core/persqueue/pq_impl_app.cpp
@@ -123,7 +123,7 @@ class TMonitoringProxy : public TActorBootstrapped<TMonitoringProxy> {
123
str << tx.TxId;
124
}
125
126
- TABLED() {str << tx.Step;}
+ TABLED() {str << GetTxStep(tx);}
127
TABLED() {str << NKikimrPQ::TTransaction_EState_Name(tx.State);}
128
TABLED() {str << tx.MinStep;}
129
TABLED() {str << tx.MaxStep;}
@@ -147,6 +147,13 @@ class TMonitoringProxy : public TActorBootstrapped<TMonitoringProxy> {
147
Die(ctx);
148
149
150
+ static TString GetTxStep(const TTransactionSnapshot& tx) {
151
+ if (tx.Step == Max<ui64>()) {
152
+ return "-";
153
+ }
154
+ return ToString(tx.Step);
155
156
+
157
void Wakeup(const TActorContext& ctx) {
158
Reply(ctx);
159
0 commit comments