Added integration tests

Author: GrigoriyPA

ydb/tests/fq/s3/test_bindings.py

@@ -586,3 +586,36 @@ def test_count_for_pg_binding(self, kikimr, s3, client, pg_syntax):
         else:
             assert result_set.columns[0].type.type_id == ydb.Type.UINT64
             assert result_set.rows[0].items[0].uint64_value == 1
+
+    @yq_all
+    @pytest.mark.parametrize("client", [{"folder_id": "my_folder"}], indirect=True)
+    def test_ast_in_failed_query_compilation(self, kikimr, s3, client):
+        resource = boto3.resource(
+            "s3",
+            endpoint_url=s3.s3_url,
+            aws_access_key_id="key",
+            aws_secret_access_key="secret_key"
+        )
+
+        bucket = resource.Bucket("bindbucket")
+        bucket.create(ACL='public-read')
+        bucket.objects.all().delete()
+
+        connection_id = client.create_storage_connection("bb", "bindbucket").result.connection_id
+
+        data_column = ydb.Column(name="data", type=ydb.Type(type_id=ydb.Type.PrimitiveTypeId.STRING))
+        client.create_object_storage_binding(name="s3binding",
+                                             path="/",
+                                             format="raw",
+                                             connection_id=connection_id,
+                                             columns=[data_column])
+
+        sql = R'''
+            SELECT some_unknown_column FROM bindings.`s3binding`;
+        '''
+
+        query_id = client.create_query("simple", sql, type=fq.QueryContent.QueryType.ANALYTICS).result.query_id
+        client.wait_query_status(query_id, fq.QueryMeta.FAILED)
+
+        ast = str(client.describe_query(query_id).result.query.ast)
+        assert ast != "", "Query ast not found"

ydb/tests/fq/yds/test_select_1.py

@@ -120,7 +120,7 @@ def test_compile_error(self, client, yq_version):
             assert "Failed to parse query" in describe_string, describe_string
 
     @yq_all
-    def test_ast_in_failed_query(self, client):
+    def test_ast_in_failed_query_runtime(self, client):
         sql = "SELECT unwrap(1 / 0)"
 
         query_id = client.create_query("simple", sql, type=fq.QueryContent.QueryType.ANALYTICS).result.query_id