fix row dispatcher tests (#24839)

Author: uzhastik

ydb/tests/fq/yds/test_row_dispatcher.py

@@ -637,7 +637,7 @@ def test_stop_start(self, kikimr, client):
 
         client.modify_query(
             query_id,
-            "continue",
+            "simple",
             sql1,
             type=fq.QueryContent.QueryType.STREAMING,
             state_load_mode=fq.StateLoadMode.EMPTY,
@@ -669,7 +669,7 @@ def test_stop_start2(self, kikimr, client):
         kikimr.compute_plane.wait_completed_checkpoints(query_id1, kikimr.compute_plane.get_completed_checkpoints(query_id1) + 2)
         stop_yds_query(client, query_id1)
 
-        client.modify_query(query_id1, "continue", sql1, type=fq.QueryContent.QueryType.STREAMING,
+        client.modify_query(query_id1, "simple", sql1, type=fq.QueryContent.QueryType.STREAMING,
                             state_load_mode=fq.StateLoadMode.EMPTY, streaming_disposition=StreamingDisposition.from_last_checkpoint())
         client.wait_query_status(query_id1, fq.QueryMeta.RUNNING)
         query_id2 = start_yds_query(kikimr, client, sql1)
@@ -680,9 +680,9 @@ def test_stop_start2(self, kikimr, client):
         stop_yds_query(client, query_id1)
         stop_yds_query(client, query_id2)
 
-        client.modify_query(query_id1, "continue", sql1, type=fq.QueryContent.QueryType.STREAMING,
+        client.modify_query(query_id1, "simple", sql1, type=fq.QueryContent.QueryType.STREAMING,
                             state_load_mode=fq.StateLoadMode.EMPTY, streaming_disposition=StreamingDisposition.from_last_checkpoint())
-        client.modify_query(query_id2, "continue", sql1, type=fq.QueryContent.QueryType.STREAMING,
+        client.modify_query(query_id2, "simple", sql1, type=fq.QueryContent.QueryType.STREAMING,
                             state_load_mode=fq.StateLoadMode.EMPTY, streaming_disposition=StreamingDisposition.from_last_checkpoint())
         wait_actor_count(kikimr, "FQ_ROW_DISPATCHER_SESSION", 1)
 
@@ -723,7 +723,7 @@ def test_stop_start_with_filter(self, kikimr, client):
 
         client.modify_query(
             query_id,
-            "continue",
+            "simple",
             sql,
             type=fq.QueryContent.QueryType.STREAMING,
             state_load_mode=fq.StateLoadMode.EMPTY,
@@ -874,7 +874,7 @@ def test_3_sessions(self, kikimr, client):
 
         client.modify_query(
             query_id1,
-            "continue",
+            "simple",
             sql1,
             type=fq.QueryContent.QueryType.STREAMING,
             state_load_mode=fq.StateLoadMode.EMPTY,
@@ -1048,7 +1048,7 @@ def test_group_by_hop_restart_query(self, kikimr, client):
 
         client.modify_query(
             query_id,
-            "continue",
+            "simple",
             sql1,
             type=fq.QueryContent.QueryType.STREAMING,
             state_load_mode=fq.StateLoadMode.FROM_LAST_CHECKPOINT,