Fix flaky TestDeleteReadRulesAfterAbortBySystem (ydb-platform#1070)

vporyadke · Feb 8, 2024 · c12cb99 · c12cb99
1 parent 16ef22d
commit c12cb99
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/ydb/tests/fq/yds/test_delete_read_rules_after_abort_by_system.py b/ydb/tests/fq/yds/test_delete_read_rules_after_abort_by_system.py
@@ -35,6 +35,8 @@ def test_delete_read_rules_after_abort_by_system(self):
         query_id = client.create_query("simple", sql, type=fq.QueryContent.QueryType.STREAMING).result.query_id
 
         client.wait_query_status(query_id, fq.QueryMeta.RUNNING)
+        self.streaming_over_kikimr.compute_plane.wait_zero_checkpoint(query_id)
+
         read_rules = list_read_rules(self.input_topic)
         assert len(read_rules) == 1, read_rules