Fixed test_write_result

GrigoriyPA · Jan 23, 2024 · 683d198 · 683d198
1 parent f962f98
commit 683d198
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/ydb/tests/fq/s3/test_s3.py b/ydb/tests/fq/s3/test_s3.py
@@ -358,9 +358,6 @@ def wait_checkpoints(require_query_is_on=False):
     @pytest.mark.parametrize("client", [{"folder_id": "my_folder"}], indirect=True)
     @pytest.mark.parametrize("kikimr", [{"compute": 3}], indirect=True)
     def test_write_result(self, kikimr, s3, client, yq_version):
-
-        # pytest.skip("Test is not stable in OSS")
-
         resource = boto3.resource(
             "s3",
             endpoint_url=s3.s3_url,
@@ -386,8 +383,11 @@ def test_write_result(self, kikimr, s3, client, yq_version):
                 fruit += "A" + str(j) + ",1,1\n"
             s3_client.put_object(Body=fruit, Bucket='wbucket', Key='fruits' + str(j) + '.csv', ContentType='text/plain')
         kikimr.control_plane.wait_bootstrap(1)
+        kikimr.compute_plane.wait_bootstrap()
         client.create_storage_connection("fruitbucket", "wbucket")
 
+        time.sleep(10)
+
         sql = R'''
             SELECT Fruit, sum(Price) as Price, sum(Weight) as Weight
             FROM fruitbucket.`fruits*`