From 683d198196cc2710432ee201b012e074521e45b2 Mon Sep 17 00:00:00 2001 From: Grigoriy Pisarenko Date: Sat, 20 Jan 2024 16:52:48 +0000 Subject: [PATCH] Fixed test_write_result --- ydb/tests/fq/s3/test_s3.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ydb/tests/fq/s3/test_s3.py b/ydb/tests/fq/s3/test_s3.py index 6a825d9e2169..3ac7339123bc 100644 --- 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*`