Merge 65d7332 into 528f54c

Alek5andr-Kotov · web-flow · commit 092449993b95 · 2024-12-30T17:47:00.000Z
diff --git a/ydb/core/persqueue/pq_impl.cpp b/ydb/core/persqueue/pq_impl.cpp
@@ -1000,9 +1000,7 @@ void TPersQueue::ReadConfig(const NKikimrClient::TKeyValueResponse::TReadResult&
             SetTxInFlyCounter();
 
             if (tx.HasStep()) {
-                if (std::make_pair(tx.GetStep(), tx.GetTxId()) >= std::make_pair(ExecStep, ExecTxId)) {
-                    PlannedTxs.emplace_back(tx.GetStep(), tx.GetTxId());
-                }
+                PlannedTxs.emplace_back(tx.GetStep(), tx.GetTxId());
             }
 
             if (tx.HasWriteId()) {

Original file line number	Diff line number	Diff line change
`@@ -1000,9 +1000,7 @@ void TPersQueue::ReadConfig(const NKikimrClient::TKeyValueResponse::TReadResult&`
`1000`	`1000`	`SetTxInFlyCounter();`
`1001`	`1001`
`1002`	`1002`	`if (tx.HasStep()) {`
`1003`		`- if (std::make_pair(tx.GetStep(), tx.GetTxId()) >= std::make_pair(ExecStep, ExecTxId)) {`
`1004`		`- PlannedTxs.emplace_back(tx.GetStep(), tx.GetTxId());`
`1005`		`- }`
	`1003`	`+ PlannedTxs.emplace_back(tx.GetStep(), tx.GetTxId());`
`1006`	`1004`	`}`
`1007`	`1005`
`1008`	`1006`	`if (tx.HasWriteId()) {`