StreamExecuteScanQueryCancelation expects SourceRead is enabled. KIKIMR-18748

This test uses breakpoint at read itterator to make pause.

1 files changed, 10 insertions, 2 deletions

diff --git a/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp b/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp
index 52b8ec45bb7..d7a4e97d3a3 100644
--- a/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp
+++ b/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp
@@ -96,7 +96,13 @@ void CreateNullSampleTables(TKikimrRunner& kikimr) {
 Y_UNIT_TEST_SUITE(KqpScan) {
 
     Y_UNIT_TEST(StreamExecuteScanQueryCancelation) {
-        TKikimrRunner kikimr;
+        NKikimrConfig::TAppConfig appConfig;
+        // This test expects SourceRead is enabled for ScanQuery
+        appConfig.MutableTableServiceConfig()->SetEnableKqpScanQuerySourceRead(true);
+        auto settings = TKikimrSettings()
+            .SetAppConfig(appConfig);
+        TKikimrRunner kikimr{settings};
+
         NKqp::TKqpCounters counters(kikimr.GetTestServer().GetRuntime()->GetAppData().Counters);
 
         NDataShard::gSkipReadIteratorResultFailPoint.Enable(-1);
@@ -115,7 +121,9 @@ Y_UNIT_TEST_SUITE(KqpScan) {
                 Sleep(TDuration::Seconds(1));
             }
 
-            UNIT_ASSERT_C(count, "Unable to wait second session actor (executing compiled program) start");
+            UNIT_ASSERT_C(count,
+                "Unable to wait second session actor (executing compiled program) start, cur count: "
+                << counters.GetActiveSessionActors()->Val());
         }
 
         NDataShard::gSkipRepliesFailPoint.Disable();