Add delay

1 files changed, 1 insertions, 1 deletions

diff --git a/ydb/core/tx/datashard/cdc_stream_scan.cpp b/ydb/core/tx/datashard/cdc_stream_scan.cpp
index 85ec7f1451..cd8a52714f 100644
--- a/ydb/core/tx/datashard/cdc_stream_scan.cpp
+++ b/ydb/core/tx/datashard/cdc_stream_scan.cpp
@@ -311,7 +311,7 @@ public:
                 << ": streamPathId# " << Request->Get()->StreamPathId);
 
             // re-schedule tx
-            Self->Execute(new TDataShard::TTxCdcStreamScanProgress(Self, Request), ctx);
+            ctx.Schedule(TDuration::Seconds(1), Request->Release().Release());
         }
     }