Merge 8d1318f into d4d07df

ydb-platform · Feb 12, 2024 · 223504f · 223504f
2 parents d4d07df + 8d1318f
commit 223504f
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 2 deletions.
diff --git a/.github/config/muted_ya.txt b/.github/config/muted_ya.txt
@@ -80,7 +80,6 @@ ydb/tests/fq/generic *
 ydb/tests/fq/mem_alloc *
 ydb/tests/fq/multi_plane *
 ydb/tests/fq/plans test_stats_mode.py.TestStatsMode.test_mode[v1-STATS_MODE_FULL-client0]
-ydb/tests/fq/restarts test_insert_restarts.py.TestS3.test_atomic_upload_commit*
 ydb/tests/fq/s3 *
 ydb/tests/fq/yds *
 ydb/tests/functional/audit *

diff --git a/ydb/library/yql/dq/actors/task_runner/task_runner_actor_local.cpp b/ydb/library/yql/dq/actors/task_runner/task_runner_actor_local.cpp
@@ -123,7 +123,6 @@ class TLocalTaskRunnerActor
         if (MemoryQuota) {
             MemoryQuota->TryReleaseQuota();
         }
-        TaskRunner.Reset();
         TActor<TLocalTaskRunnerActor>::PassAway();
     }
 

diff --git a/ydb/tests/fq/restarts/test_insert_restarts.py b/ydb/tests/fq/restarts/test_insert_restarts.py
@@ -93,6 +93,7 @@ def test_atomic_upload_commit(self, kikimr, s3, client):
             assert time.time() < deadline, f"Insert not finished for already {time.time() - start} seconds"
             time.sleep(0.001)
 
+        kikimr.compute_plane.wait_bootstrap()
         client.wait_query(query_id, statuses=[fq.QueryMeta.COMPLETED, fq.QueryMeta.ABORTED_BY_SYSTEM, fq.QueryMeta.FAILED], timeout=timeout)
 
         final_number_rows = self.run_atomic_upload_check_query(client, bucket, "ibucket", "insert/", "csv_with_names")