File tree Expand file tree Collapse file tree 1 file changed +19
-6
lines changed
tests/integration/test_postpone_failed_tasks Expand file tree Collapse file tree 1 file changed +19
-6
lines changed Original file line number Diff line number Diff line change @@ -247,9 +247,22 @@ def test_no_backoff_after_killing_mutation(started_cluster, replicated_table):
247247 node .query (
248248 f"KILL MUTATION WHERE table = 'test_table' AND mutation_id = '{ mutation_ids [0 ]} '"
249249 )
250- node .rotate_logs ()
251- assert not node .contains_in_log (
252- REPLICATED_POSTPONE_LOG
253- if replicated_table
254- else NON_REPLICATED_POSTPONE_MUTATION_LOG
255- )
250+
251+ retry_count = 10
252+ for retry in range (retry_count ):
253+ node .rotate_logs ()
254+ try :
255+ node .wait_for_log_line (
256+ (
257+ REPLICATED_POSTPONE_LOG
258+ if replicated_table
259+ else NON_REPLICATED_POSTPONE_MUTATION_LOG
260+ ),
261+ timeout = 5 ,
262+ )
263+ except Exception :
264+ ## the log line not found.
265+ break
266+
267+ if retry == retry_count - 1 :
268+ assert False , "After killing the mutatuion it is still executed"
You can’t perform that action at this time.
0 commit comments