2025-12-12 13:27:11,437 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-12-12 13:27:11,437 - INFO - ya.test - pytest_runtest_setup: test_block_insert_enable[v1-client0]
2025-12-12 13:27:11,437 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-12-12 13:27:11,438 - INFO - ya.test - pytest_runtest_setup: Test setup
2025-12-12 13:27:11,508 - INFO - ya.test - pytest_runtest_call: Test call (class_name: test_insert.py::TestS3, test_name: test_block_insert_enable[v1-client0])
2025-12-12 13:27:11,509 - DEBUG - botocore.hooks - _emit: Event choose-service-name: calling handler <function handle_service_name_alias at 0x7f51af1290d0>
2025-12-12 13:27:11,512 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function add_generate_presigned_post at 0x7f51af238dd0>
2025-12-12 13:27:11,512 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function lazy_call.<locals>._handler at 0x7f51ae4d8050>
2025-12-12 13:27:11,513 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function add_generate_presigned_url at 0x7f51af238ad0>
2025-12-12 13:27:11,519 - DEBUG - botocore.endpoint - create_endpoint: Setting s3 timeout as (60, 60)
2025-12-12 13:27:11,523 - DEBUG - botocore.client - _register_legacy_retries: Registering retry handlers for service: s3
2025-12-12 13:27:11,524 - DEBUG - botocore.utils - register: Registering S3 region redirector handler
2025-12-12 13:27:11,525 - DEBUG - boto3.resources.factory - load_from_definition: Loading s3:s3
2025-12-12 13:27:11,526 - DEBUG - boto3.resources.factory - load_from_definition: Loading s3:Bucket
2025-12-12 13:27:11,528 - DEBUG - boto3.resources.model - _load_name_with_category: Renaming Bucket attribute name
2025-12-12 13:27:11,529 - DEBUG - botocore.hooks - _emit: Event creating-resource-class.s3.Bucket: calling handler <function lazy_call.<locals>._handler at 0x7f51ae4d8ad0>
2025-12-12 13:27:11,533 - DEBUG - boto3.resources.action - __call__: Calling s3:create_bucket with {'Bucket': 'insert_bucket', 'ACL': 'public-read-write'}
2025-12-12 13:27:11,534 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <function validate_bucket_name at 0x7f51af12af90>
2025-12-12 13:27:11,534 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <function remove_bucket_from_url_paths_from_model at 0x7f51af151850>
2025-12-12 13:27:11,534 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <bound method S3RegionRedirectorv2.annotate_request_context of <botocore.utils.S3RegionRedirectorv2 object at 0x7f51936a05b0>>
2025-12-12 13:27:11,534 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <function generate_idempotent_uuid at 0x7f51af12ad50>
2025-12-12 13:27:11,535 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <function customize_endpoint_resolver_builtins at 0x7f51af151a90>
2025-12-12 13:27:11,535 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <bound method S3RegionRedirectorv2.redirect_from_cache of <botocore.utils.S3RegionRedirectorv2 object at 0x7f51936a05b0>>
2025-12-12 13:27:11,536 - DEBUG - botocore.regions - construct_endpoint: Calling endpoint provider with parameters: {'Bucket': 'insert_bucket', 'Region': 'yandex', 'UseFIPS': False, 'UseDualStack': False, 'Endpoint': 'http://localhost:12075', 'ForcePathStyle': True, 'Accelerate': False, 'UseGlobalEndpoint': False, 'DisableAccessPoints': True, 'DisableMultiRegionAccessPoints': False, 'UseArnRegion': True}
2025-12-12 13:27:11,537 - DEBUG - botocore.regions - construct_endpoint: Endpoint provider result: http://localhost:12075/insert_bucket
2025-12-12 13:27:11,538 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selecting from endpoint provider's list of auth schemes: "sigv4". User selected auth scheme is: "None"
2025-12-12 13:27:11,538 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selected auth type "v4" as "v4" with signing context params: {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}
2025-12-12 13:27:11,539 - DEBUG - botocore.hooks - _emit: Event before-call.s3.CreateBucket: calling handler <function add_expect_header at 0x7f51af12b410>
2025-12-12 13:27:11,540 - DEBUG - botocore.hooks - _emit: Event before-call.s3.CreateBucket: calling handler <function add_recursion_detection_header at 0x7f51af129310>
2025-12-12 13:27:11,540 - DEBUG - botocore.hooks - _emit: Event before-call.s3.CreateBucket: calling handler <function inject_api_version_header_if_needed at 0x7f51af150e90>
2025-12-12 13:27:11,543 - DEBUG - botocore.endpoint - make_request: Making request for OperationModel(name=CreateBucket) with params: {'url_path': '', 'query_string': {}, 'method': 'PUT', 'headers': {'x-amz-acl': 'public-read-write', 'User-Agent': 'Boto3/1.29.6 md/Botocore#1.31.80 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.9 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.31.80 Resource'}, 'body': b'', 'auth_path': '/insert_bucket/', 'url': 'http://localhost:12075/insert_bucket', 'context': {'client_region': 'yandex', 'client_config': <botocore.config.Config object at 0x7f51ae628790>, 'has_streaming_input': False, 'auth_type': 'v4', 's3_redirect': {'redirected': False, 'bucket': 'insert_bucket', 'params': {'Bucket': 'insert_bucket', 'ACL': 'public-read-write'}}, 'signing': {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}}}
2025-12-12 13:27:11,549 - DEBUG - botocore.hooks - _emit: Event request-created.s3.CreateBucket: calling handler <bound method RequestSigner.handler of <botocore.signers.RequestSigner object at 0x7f51ae62b210>>
2025-12-12 13:27:11,551 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.CreateBucket: calling handler <bound method ClientCreator._default_s3_presign_to_sigv2 of <botocore.client.ClientCreator object at 0x7f519404a1d0>>
2025-12-12 13:27:11,557 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.CreateBucket: calling handler <function set_operation_specific_signer at 0x7f51af12abd0>
2025-12-12 13:27:11,557 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.CreateBucket: calling handler <function remove_arn_from_signing_path at 0x7f51af1519d0>
2025-12-12 13:27:11,574 - DEBUG - botocore.auth - add_auth: Calculating signature using v4 auth.
2025-12-12 13:27:11,575 - DEBUG - botocore.auth - add_auth: CanonicalRequest:
PUT
/insert_bucket

host:localhost:12075
x-amz-acl:public-read-write
x-amz-content-sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
x-amz-date:20251212T132711Z

host;x-amz-acl;x-amz-content-sha256;x-amz-date
e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
2025-12-12 13:27:11,575 - DEBUG - botocore.auth - add_auth: StringToSign:
AWS4-HMAC-SHA256
20251212T132711Z
20251212/yandex/s3/aws4_request
b0c9c03e51fdd3713ac4cb30ca06e4d28e533cab8526db4d9c84288c7b71498f
2025-12-12 13:27:11,576 - DEBUG - botocore.auth - add_auth: Signature:
75373ed9181c613b42fe901105dae0a477d6a4928d1db5dcb9be01060d12847a
2025-12-12 13:27:11,576 - DEBUG - botocore.hooks - _emit: Event request-created.s3.CreateBucket: calling handler <function add_retry_headers at 0x7f51af151790>
2025-12-12 13:27:11,576 - DEBUG - botocore.endpoint - _do_get_response: Sending http request: <AWSPreparedRequest stream_output=False, method=PUT, url=http://localhost:12075/insert_bucket, headers={'x-amz-acl': b'public-read-write', 'User-Agent': b'Boto3/1.29.6 md/Botocore#1.31.80 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.9 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.31.80 Resource', 'X-Amz-Date': b'20251212T132711Z', 'X-Amz-Content-SHA256': b'e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855', 'Authorization': b'AWS4-HMAC-SHA256 Credential=key/20251212/yandex/s3/aws4_request, SignedHeaders=host;x-amz-acl;x-amz-content-sha256;x-amz-date, Signature=75373ed9181c613b42fe901105dae0a477d6a4928d1db5dcb9be01060d12847a', 'amz-sdk-invocation-id': b'2a7344c5-b4e6-4447-967a-c61c839702fb', 'amz-sdk-request': b'attempt=1', 'Content-Length': '0'}>
2025-12-12 13:27:11,591 - DEBUG - botocore.parsers - parse: Response headers: {'Server': 'Werkzeug/2.2.3 Python/3.12.9', 'Date': 'Fri, 12 Dec 2025 13:27:11 GMT', 'x-amzn-requestid': 'OjZoGhjXBV34jcdthABXjTXW0sZEWgUmlfc5LuC1SJ8BSpQkMTqA', 'Content-Type': 'text/html; charset=utf-8', 'Content-Length': '167', 'Access-Control-Allow-Origin': '*', 'Connection': 'close'}
2025-12-12 13:27:11,592 - DEBUG - botocore.parsers - parse: Response body:
b'<CreateBucketResponse xmlns="http://s3.amazonaws.com/doc/2006-03-01"><CreateBucketResponse><Bucket>insert_bucket</Bucket></CreateBucketResponse></CreateBucketResponse>'
2025-12-12 13:27:11,593 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.CreateBucket: calling handler <botocore.retryhandler.RetryHandler object at 0x7f51940c0100>
2025-12-12 13:27:11,593 - DEBUG - botocore.retryhandler - __call__: No retry needed.
2025-12-12 13:27:11,593 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.CreateBucket: calling handler <bound method S3RegionRedirectorv2.redirect_from_error of <botocore.utils.S3RegionRedirectorv2 object at 0x7f51936a05b0>>
2025-12-12 13:27:11,594 - DEBUG - boto3.resources.action - __call__: Response: {'ResponseMetadata': {'RequestId': 'OjZoGhjXBV34jcdthABXjTXW0sZEWgUmlfc5LuC1SJ8BSpQkMTqA', 'HTTPStatusCode': 200, 'HTTPHeaders': {'server': 'Werkzeug/2.2.3 Python/3.12.9', 'date': 'Fri, 12 Dec 2025 13:27:11 GMT', 'x-amzn-requestid': 'OjZoGhjXBV34jcdthABXjTXW0sZEWgUmlfc5LuC1SJ8BSpQkMTqA', 'content-type': 'text/html; charset=utf-8', 'content-length': '167', 'access-control-allow-origin': '*', 'connection': 'close'}, 'RetryAttempts': 0}}
2025-12-12 13:27:11,594 - DEBUG - boto3.resources.collection - pages: Calling paginated s3:list_objects with {'Bucket': 'insert_bucket'}
2025-12-12 13:27:11,596 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function set_list_objects_encoding_type_url at 0x7f51af150890>
2025-12-12 13:27:11,596 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function validate_bucket_name at 0x7f51af12af90>
2025-12-12 13:27:11,596 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function remove_bucket_from_url_paths_from_model at 0x7f51af151850>
2025-12-12 13:27:11,596 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <bound method S3RegionRedirectorv2.annotate_request_context of <botocore.utils.S3RegionRedirectorv2 object at 0x7f51936a05b0>>
2025-12-12 13:27:11,596 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function generate_idempotent_uuid at 0x7f51af12ad50>
2025-12-12 13:27:11,597 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <function customize_endpoint_resolver_builtins at 0x7f51af151a90>
2025-12-12 13:27:11,597 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <bound method S3RegionRedirectorv2.redirect_from_cache of <botocore.utils.S3RegionRedirectorv2 object at 0x7f51936a05b0>>
2025-12-12 13:27:11,597 - DEBUG - botocore.regions - construct_endpoint: Calling endpoint provider with parameters: {'Bucket': 'insert_bucket', 'Region': 'yandex', 'UseFIPS': False, 'UseDualStack': False, 'Endpoint': 'http://localhost:12075', 'ForcePathStyle': True, 'Accelerate': False, 'UseGlobalEndpoint': False, 'DisableMultiRegionAccessPoints': False, 'UseArnRegion': True}
2025-12-12 13:27:11,599 - DEBUG - botocore.regions - construct_endpoint: Endpoint provider result: http://localhost:12075/insert_bucket
2025-12-12 13:27:11,600 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selecting from endpoint provider's list of auth schemes: "sigv4". User selected auth scheme is: "None"
2025-12-12 13:27:11,601 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selected auth type "v4" as "v4" with signing context params: {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}
2025-12-12 13:27:11,602 - DEBUG - botocore.hooks - _emit: Event before-call.s3.ListObjects: calling handler <function add_expect_header at 0x7f51af12b410>
2025-12-12 13:27:11,604 - DEBUG - botocore.hooks - _emit: Event before-call.s3.ListObjects: calling handler <function add_recursion_detection_header at 0x7f51af129310>
2025-12-12 13:27:11,604 - DEBUG - botocore.hooks - _emit: Event before-call.s3.ListObjects: calling handler <function inject_api_version_header_if_needed at 0x7f51af150e90>
2025-12-12 13:27:11,605 - DEBUG - botocore.endpoint - make_request: Making request for OperationModel(name=ListObjects) with params: {'url_path': '', 'query_string': {'encoding-type': 'url'}, 'method': 'GET', 'headers': {'User-Agent': 'Boto3/1.29.6 md/Botocore#1.31.80 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.9 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.31.80 Resource'}, 'body': b'', 'auth_path': '/insert_bucket/', 'url': 'http://localhost:12075/insert_bucket?encoding-type=url', 'context': {'client_region': 'yandex', 'client_config': <botocore.config.Config object at 0x7f51ae628790>, 'has_streaming_input': False, 'auth_type': 'v4', 'encoding_type_auto_set': True, 's3_redirect': {'redirected': False, 'bucket': 'insert_bucket', 'params': {'Bucket': 'insert_bucket', 'EncodingType': 'url'}}, 'signing': {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}}}
2025-12-12 13:27:11,606 - DEBUG - botocore.hooks - _emit: Event request-created.s3.ListObjects: calling handler <bound method RequestSigner.handler of <botocore.signers.RequestSigner object at 0x7f51ae62b210>>
2025-12-12 13:27:11,606 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.ListObjects: calling handler <bound method ClientCreator._default_s3_presign_to_sigv2 of <botocore.client.ClientCreator object at 0x7f519404a1d0>>
2025-12-12 13:27:11,607 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.ListObjects: calling handler <function set_operation_specific_signer at 0x7f51af12abd0>
2025-12-12 13:27:11,608 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.ListObjects: calling handler <function remove_arn_from_signing_path at 0x7f51af1519d0>
2025-12-12 13:27:11,608 - DEBUG - botocore.auth - add_auth: Calculating signature using v4 auth.
2025-12-12 13:27:11,608 - DEBUG - botocore.auth - add_auth: CanonicalRequest:
GET
/insert_bucket
encoding-type=url
host:localhost:12075
x-amz-content-sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
x-amz-date:20251212T132711Z

host;x-amz-content-sha256;x-amz-date
e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
2025-12-12 13:27:11,609 - DEBUG - botocore.auth - add_auth: StringToSign:
AWS4-HMAC-SHA256
20251212T132711Z
20251212/yandex/s3/aws4_request
cb8e9afd37cfd131684c2801ac358d1f29c81f31fbbfbc38851e2e8ec6e2b1b3
2025-12-12 13:27:11,609 - DEBUG - botocore.auth - add_auth: Signature:
d3537e20def65c0e0c59c8a92711ee1ba42c5b7af4420b38aa9439a32a256442
2025-12-12 13:27:11,609 - DEBUG - botocore.hooks - _emit: Event request-created.s3.ListObjects: calling handler <function add_retry_headers at 0x7f51af151790>
2025-12-12 13:27:11,610 - DEBUG - botocore.endpoint - _do_get_response: Sending http request: <AWSPreparedRequest stream_output=False, method=GET, url=http://localhost:12075/insert_bucket?encoding-type=url, headers={'User-Agent': b'Boto3/1.29.6 md/Botocore#1.31.80 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.9 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.31.80 Resource', 'X-Amz-Date': b'20251212T132711Z', 'X-Amz-Content-SHA256': b'e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855', 'Authorization': b'AWS4-HMAC-SHA256 Credential=key/20251212/yandex/s3/aws4_request, SignedHeaders=host;x-amz-content-sha256;x-amz-date, Signature=d3537e20def65c0e0c59c8a92711ee1ba42c5b7af4420b38aa9439a32a256442', 'amz-sdk-invocation-id': b'b5f00d54-8e41-485f-ba51-49be9f37f1ef', 'amz-sdk-request': b'attempt=1'}>
2025-12-12 13:27:11,616 - DEBUG - botocore.parsers - parse: Response headers: {'Server': 'Werkzeug/2.2.3 Python/3.12.9', 'Date': 'Fri, 12 Dec 2025 13:27:11 GMT', 'x-amzn-requestid': 'gpxZi8Eb2w5chgvnphAbxexIHfqRUJdNjomaL2JMGZrL08dLEQop', 'Content-Type': 'text/html; charset=utf-8', 'Content-Length': '236', 'Access-Control-Allow-Origin': '*', 'Connection': 'close'}
2025-12-12 13:27:11,617 - DEBUG - botocore.parsers - parse: Response body:
b'<?xml version="1.0" encoding="UTF-8"?><ListBucketResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/"><Name>insert_bucket</Name><MaxKeys>1000</MaxKeys><EncodingType>url</EncodingType><IsTruncated>false</IsTruncated></ListBucketResult>'
2025-12-12 13:27:11,618 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.ListObjects: calling handler <botocore.retryhandler.RetryHandler object at 0x7f51940c0100>
2025-12-12 13:27:11,618 - DEBUG - botocore.retryhandler - __call__: No retry needed.
2025-12-12 13:27:11,618 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.ListObjects: calling handler <bound method S3RegionRedirectorv2.redirect_from_error of <botocore.utils.S3RegionRedirectorv2 object at 0x7f51936a05b0>>
2025-12-12 13:27:11,619 - DEBUG - botocore.hooks - _emit: Event after-call.s3.ListObjects: calling handler <function decode_list_object at 0x7f51af150950>
2025-12-12 13:27:11,619 - DEBUG - boto3.resources.factory - load_from_definition: Loading s3:ObjectSummary
2025-12-12 13:27:11,620 - DEBUG - boto3.resources.model - _load_name_with_category: Renaming ObjectSummary attribute key
2025-12-12 13:27:11,621 - DEBUG - botocore.hooks - _emit: Event creating-resource-class.s3.ObjectSummary: calling handler <function lazy_call.<locals>._handler at 0x7f51ae4d8c50>
2025-12-12 13:27:11,676 - DEBUG - root - get_insert_test_query: INSERT INTO `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (FORMAT = "parquet") SELECT
Unwrap(CAST(2 AS Int8)) AS `Int8Col`,
Just(Unwrap(CAST(2 AS Int8))) AS `OptInt8Col`,
CAST(NULL AS Int8) AS `NullInt8Col`,
Unwrap(CAST(-3 AS Int16)) AS `Int16Col`,
Just(Unwrap(CAST(-3 AS Int16))) AS `OptInt16Col`,
CAST(NULL AS Int16) AS `NullInt16Col`,
Unwrap(CAST(4 AS Int32)) AS `Int32Col`,
Just(Unwrap(CAST(4 AS Int32))) AS `OptInt32Col`,
CAST(NULL AS Int32) AS `NullInt32Col`,
Unwrap(CAST(-5 AS Int64)) AS `Int64Col`,
Just(Unwrap(CAST(-5 AS Int64))) AS `OptInt64Col`,
CAST(NULL AS Int64) AS `NullInt64Col`,
Unwrap(CAST(6 AS Uint8)) AS `Uint8Col`,
Just(Unwrap(CAST(6 AS Uint8))) AS `OptUint8Col`,
CAST(NULL AS Uint8) AS `NullUint8Col`,
Unwrap(CAST(7 AS Uint16)) AS `Uint16Col`,
Just(Unwrap(CAST(7 AS Uint16))) AS `OptUint16Col`,
CAST(NULL AS Uint16) AS `NullUint16Col`,
Unwrap(CAST(8 AS Uint32)) AS `Uint32Col`,
Just(Unwrap(CAST(8 AS Uint32))) AS `OptUint32Col`,
CAST(NULL AS Uint32) AS `NullUint32Col`,
Unwrap(CAST(9 AS Uint64)) AS `Uint64Col`,
Just(Unwrap(CAST(9 AS Uint64))) AS `OptUint64Col`,
CAST(NULL AS Uint64) AS `NullUint64Col`,
Unwrap(CAST(1 AS Bool)) AS `BoolCol`,
Just(Unwrap(CAST(1 AS Bool))) AS `OptBoolCol`,
CAST(NULL AS Bool) AS `NullBoolCol`,
Unwrap(CAST(10.5 AS Float)) AS `FloatCol`,
Just(Unwrap(CAST(10.5 AS Float))) AS `OptFloatCol`,
CAST(NULL AS Float) AS `NullFloatCol`,
Unwrap(CAST(11.9 AS Double)) AS `DoubleCol`,
Just(Unwrap(CAST(11.9 AS Double))) AS `OptDoubleCol`,
CAST(NULL AS Double) AS `NullDoubleCol`,
Unwrap(CAST("STR_1" AS String)) AS `StringCol`,
Just(Unwrap(CAST("STR_1" AS String))) AS `OptStringCol`,
CAST(NULL AS String) AS `NullStringCol`,
Unwrap(CAST("STR_2" AS Utf8)) AS `Utf8Col`,
Just(Unwrap(CAST("STR_2" AS Utf8))) AS `OptUtf8Col`,
CAST(NULL AS Utf8) AS `NullUtf8Col`,
Unwrap(CAST("\"STR_3\"" AS Json)) AS `JsonCol`,
Just(Unwrap(CAST("\"STR_3\"" AS Json))) AS `OptJsonCol`,
CAST(NULL AS Json) AS `NullJsonCol`,
Unwrap(CAST(CurrentUtcDate() AS Date)) AS `DateCol`,
Just(Unwrap(CAST(CurrentUtcDate() AS Date))) AS `OptDateCol`,
CAST(NULL AS Date) AS `NullDateCol`,
Unwrap(CAST("2025-05-09T18:44:58Z" AS Datetime)) AS `DatetimeCol`,
Just(Unwrap(CAST("2025-05-09T18:44:58Z" AS Datetime))) AS `OptDatetimeCol`,
CAST(NULL AS Datetime) AS `NullDatetimeCol`,
Unwrap(CAST("2025-05-09T18:44:58.678906Z" AS Timestamp)) AS `TimestampCol`,
Just(Unwrap(CAST("2025-05-09T18:44:58.678906Z" AS Timestamp))) AS `OptTimestampCol`,
CAST(NULL AS Timestamp) AS `NullTimestampCol`,
Unwrap(CAST(CurrentTzDate(1) AS TzDate)) AS `TzDateCol`,
Just(Unwrap(CAST(CurrentTzDate(1) AS TzDate))) AS `OptTzDateCol`,
CAST(NULL AS TzDate) AS `NullTzDateCol`,
Unwrap(CAST("2025-05-09T21:45:58,Europe/Moscow" AS TzDateTime)) AS `TzDateTimeCol`,
Just(Unwrap(CAST("2025-05-09T21:45:58,Europe/Moscow" AS TzDateTime))) AS `OptTzDateTimeCol`,
CAST(NULL AS TzDateTime) AS `NullTzDateTimeCol`,
Unwrap(CAST("2025-05-09T21:45:58.222886,Europe/Moscow" AS TzTimestamp)) AS `TzTimestampCol`,
Just(Unwrap(CAST("2025-05-09T21:45:58.222886,Europe/Moscow" AS TzTimestamp))) AS `OptTzTimestampCol`,
CAST(NULL AS TzTimestamp) AS `NullTzTimestampCol`,

2025-12-12 13:27:11,677 - DEBUG - root - create_query_impl: Request: content {
  type: ANALYTICS
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "INSERT INTO `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (FORMAT = \"parquet\") SELECT\nUnwrap(CAST(2 AS Int8)) AS `Int8Col`,\nJust(Unwrap(CAST(2 AS Int8))) AS `OptInt8Col`,\nCAST(NULL AS Int8) AS `NullInt8Col`,\nUnwrap(CAST(-3 AS Int16)) AS `Int16Col`,\nJust(Unwrap(CAST(-3 AS Int16))) AS `OptInt16Col`,\nCAST(NULL AS Int16) AS `NullInt16Col`,\nUnwrap(CAST(4 AS Int32)) AS `Int32Col`,\nJust(Unwrap(CAST(4 AS Int32))) AS `OptInt32Col`,\nCAST(NULL AS Int32) AS `NullInt32Col`,\nUnwrap(CAST(-5 AS Int64)) AS `Int64Col`,\nJust(Unwrap(CAST(-5 AS Int64))) AS `OptInt64Col`,\nCAST(NULL AS Int64) AS `NullInt64Col`,\nUnwrap(CAST(6 AS Uint8)) AS `Uint8Col`,\nJust(Unwrap(CAST(6 AS Uint8))) AS `OptUint8Col`,\nCAST(NULL AS Uint8) AS `NullUint8Col`,\nUnwrap(CAST(7 AS Uint16)) AS `Uint16Col`,\nJust(Unwrap(CAST(7 AS Uint16))) AS `OptUint16Col`,\nCAST(NULL AS Uint16) AS `NullUint16Col`,\nUnwrap(CAST(8 AS Uint32)) AS `Uint32Col`,\nJust(Unwrap(CAST(8 AS Uint32))) AS `OptUint32Col`,\nCAST(NULL AS Uint32) AS `NullUint32Col`,\nUnwrap(CAST(9 AS Uint64)) AS `Uint64Col`,\nJust(Unwrap(CAST(9 AS Uint64))) AS `OptUint64Col`,\nCAST(NULL AS Uint64) AS `NullUint64Col`,\nUnwrap(CAST(1 AS Bool)) AS `BoolCol`,\nJust(Unwrap(CAST(1 AS Bool))) AS `OptBoolCol`,\nCAST(NULL AS Bool) AS `NullBoolCol`,\nUnwrap(CAST(10.5 AS Float)) AS `FloatCol`,\nJust(Unwrap(CAST(10.5 AS Float))) AS `OptFloatCol`,\nCAST(NULL AS Float) AS `NullFloatCol`,\nUnwrap(CAST(11.9 AS Double)) AS `DoubleCol`,\nJust(Unwrap(CAST(11.9 AS Double))) AS `OptDoubleCol`,\nCAST(NULL AS Double) AS `NullDoubleCol`,\nUnwrap(CAST(\"STR_1\" AS String)) AS `StringCol`,\nJust(Unwrap(CAST(\"STR_1\" AS String))) AS `OptStringCol`,\nCAST(NULL AS String) AS `NullStringCol`,\nUnwrap(CAST(\"STR_2\" AS Utf8)) AS `Utf8Col`,\nJust(Unwrap(CAST(\"STR_2\" AS Utf8))) AS `OptUtf8Col`,\nCAST(NULL AS Utf8) AS `NullUtf8Col`,\nUnwrap(CAST(\"\\\"STR_3\\\"\" AS Json)) AS `JsonCol`,\nJust(Unwrap(CAST(\"\\\"STR_3\\\"\" AS Json))) AS `OptJsonCol`,\nCAST(NULL AS Json) AS `NullJsonCol`,\nUnwrap(CAST(CurrentUtcDate() AS Date)) AS `DateCol`,\nJust(Unwrap(CAST(CurrentUtcDate() AS Date))) AS `OptDateCol`,\nCAST(NULL AS Date) AS `NullDateCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime)) AS `DatetimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime))) AS `OptDatetimeCol`,\nCAST(NULL AS Datetime) AS `NullDatetimeCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp)) AS `TimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp))) AS `OptTimestampCol`,\nCAST(NULL AS Timestamp) AS `NullTimestampCol`,\nUnwrap(CAST(CurrentTzDate(1) AS TzDate)) AS `TzDateCol`,\nJust(Unwrap(CAST(CurrentTzDate(1) AS TzDate))) AS `OptTzDateCol`,\nCAST(NULL AS TzDate) AS `NullTzDateCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime)) AS `TzDateTimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime))) AS `OptTzDateTimeCol`,\nCAST(NULL AS TzDateTime) AS `NullTzDateTimeCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp)) AS `TzTimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp))) AS `OptTzTimestampCol`,\nCAST(NULL AS TzTimestamp) AS `NullTzTimestampCol`,\n"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "8c80de5a-c692-4c68-b05a-a7bfe37135ca"

2025-12-12 13:27:11,702 - DEBUG - root - create_query_impl: Result: query_id: "ptqudq7r3v4pbl5td5l9"

2025-12-12 13:27:11,714 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudq7r3v4pbl5td5l9"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1765546031
        nanos: 684224000
      }
      modified_at {
        seconds: 1765546031
        nanos: 684224000
      }
      revision: 1
    }
    execute_mode: RUN
    status: STARTING
    last_job_query_revision: 1
    last_job_id: "ptjudq7r3v4p994q1gev-ptqudq7r3v4pbl5td5l9"
    started_by: "root@builtin"
    submitted_at {
      seconds: 1765546031
      nanos: 684224000
    }
  }
  content {
    type: ANALYTICS
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "INSERT INTO `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (FORMAT = \"parquet\") SELECT\nUnwrap(CAST(2 AS Int8)) AS `Int8Col`,\nJust(Unwrap(CAST(2 AS Int8))) AS `OptInt8Col`,\nCAST(NULL AS Int8) AS `NullInt8Col`,\nUnwrap(CAST(-3 AS Int16)) AS `Int16Col`,\nJust(Unwrap(CAST(-3 AS Int16))) AS `OptInt16Col`,\nCAST(NULL AS Int16) AS `NullInt16Col`,\nUnwrap(CAST(4 AS Int32)) AS `Int32Col`,\nJust(Unwrap(CAST(4 AS Int32))) AS `OptInt32Col`,\nCAST(NULL AS Int32) AS `NullInt32Col`,\nUnwrap(CAST(-5 AS Int64)) AS `Int64Col`,\nJust(Unwrap(CAST(-5 AS Int64))) AS `OptInt64Col`,\nCAST(NULL AS Int64) AS `NullInt64Col`,\nUnwrap(CAST(6 AS Uint8)) AS `Uint8Col`,\nJust(Unwrap(CAST(6 AS Uint8))) AS `OptUint8Col`,\nCAST(NULL AS Uint8) AS `NullUint8Col`,\nUnwrap(CAST(7 AS Uint16)) AS `Uint16Col`,\nJust(Unwrap(CAST(7 AS Uint16))) AS `OptUint16Col`,\nCAST(NULL AS Uint16) AS `NullUint16Col`,\nUnwrap(CAST(8 AS Uint32)) AS `Uint32Col`,\nJust(Unwrap(CAST(8 AS Uint32))) AS `OptUint32Col`,\nCAST(NULL AS Uint32) AS `NullUint32Col`,\nUnwrap(CAST(9 AS Uint64)) AS `Uint64Col`,\nJust(Unwrap(CAST(9 AS Uint64))) AS `OptUint64Col`,\nCAST(NULL AS Uint64) AS `NullUint64Col`,\nUnwrap(CAST(1 AS Bool)) AS `BoolCol`,\nJust(Unwrap(CAST(1 AS Bool))) AS `OptBoolCol`,\nCAST(NULL AS Bool) AS `NullBoolCol`,\nUnwrap(CAST(10.5 AS Float)) AS `FloatCol`,\nJust(Unwrap(CAST(10.5 AS Float))) AS `OptFloatCol`,\nCAST(NULL AS Float) AS `NullFloatCol`,\nUnwrap(CAST(11.9 AS Double)) AS `DoubleCol`,\nJust(Unwrap(CAST(11.9 AS Double))) AS `OptDoubleCol`,\nCAST(NULL AS Double) AS `NullDoubleCol`,\nUnwrap(CAST(\"STR_1\" AS String)) AS `StringCol`,\nJust(Unwrap(CAST(\"STR_1\" AS String))) AS `OptStringCol`,\nCAST(NULL AS String) AS `NullStringCol`,\nUnwrap(CAST(\"STR_2\" AS Utf8)) AS `Utf8Col`,\nJust(Unwrap(CAST(\"STR_2\" AS Utf8))) AS `OptUtf8Col`,\nCAST(NULL AS Utf8) AS `NullUtf8Col`,\nUnwrap(CAST(\"\\\"STR_3\\\"\" AS Json)) AS `JsonCol`,\nJust(Unwrap(CAST(\"\\\"STR_3\\\"\" AS Json))) AS `OptJsonCol`,\nCAST(NULL AS Json) AS `NullJsonCol`,\nUnwrap(CAST(CurrentUtcDate() AS Date)) AS `DateCol`,\nJust(Unwrap(CAST(CurrentUtcDate() AS Date))) AS `OptDateCol`,\nCAST(NULL AS Date) AS `NullDateCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime)) AS `DatetimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime))) AS `OptDatetimeCol`,\nCAST(NULL AS Datetime) AS `NullDatetimeCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp)) AS `TimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp))) AS `OptTimestampCol`,\nCAST(NULL AS Timestamp) AS `NullTimestampCol`,\nUnwrap(CAST(CurrentTzDate(1) AS TzDate)) AS `TzDateCol`,\nJust(Unwrap(CAST(CurrentTzDate(1) AS TzDate))) AS `OptTzDateCol`,\nCAST(NULL AS TzDate) AS `NullTzDateCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime)) AS `TzDateTimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime))) AS `OptTzDateTimeCol`,\nCAST(NULL AS TzDateTime) AS `NullTzDateTimeCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp)) AS `TzTimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp))) AS `OptTzTimestampCol`,\nCAST(NULL AS TzTimestamp) AS `NullTzTimestampCol`,\n"
    syntax: YQL_V1
  }
}

2025-12-12 13:27:12,233 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudq7r3v4pbl5td5l9"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1765546031
        nanos: 684224000
      }
      modified_at {
        seconds: 1765546031
        nanos: 684224000
      }
      revision: 1
    }
    started_at {
      seconds: 1765546031
      nanos: 977000000
    }
    execute_mode: RUN
    status: RUNNING
    last_job_query_revision: 1
    last_job_id: "ptjudq7r3v4p994q1gev-ptqudq7r3v4pbl5td5l9"
    started_by: "root@builtin"
    submitted_at {
      seconds: 1765546031
      nanos: 684224000
    }
  }
  content {
    type: ANALYTICS
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "INSERT INTO `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (FORMAT = \"parquet\") SELECT\nUnwrap(CAST(2 AS Int8)) AS `Int8Col`,\nJust(Unwrap(CAST(2 AS Int8))) AS `OptInt8Col`,\nCAST(NULL AS Int8) AS `NullInt8Col`,\nUnwrap(CAST(-3 AS Int16)) AS `Int16Col`,\nJust(Unwrap(CAST(-3 AS Int16))) AS `OptInt16Col`,\nCAST(NULL AS Int16) AS `NullInt16Col`,\nUnwrap(CAST(4 AS Int32)) AS `Int32Col`,\nJust(Unwrap(CAST(4 AS Int32))) AS `OptInt32Col`,\nCAST(NULL AS Int32) AS `NullInt32Col`,\nUnwrap(CAST(-5 AS Int64)) AS `Int64Col`,\nJust(Unwrap(CAST(-5 AS Int64))) AS `OptInt64Col`,\nCAST(NULL AS Int64) AS `NullInt64Col`,\nUnwrap(CAST(6 AS Uint8)) AS `Uint8Col`,\nJust(Unwrap(CAST(6 AS Uint8))) AS `OptUint8Col`,\nCAST(NULL AS Uint8) AS `NullUint8Col`,\nUnwrap(CAST(7 AS Uint16)) AS `Uint16Col`,\nJust(Unwrap(CAST(7 AS Uint16))) AS `OptUint16Col`,\nCAST(NULL AS Uint16) AS `NullUint16Col`,\nUnwrap(CAST(8 AS Uint32)) AS `Uint32Col`,\nJust(Unwrap(CAST(8 AS Uint32))) AS `OptUint32Col`,\nCAST(NULL AS Uint32) AS `NullUint32Col`,\nUnwrap(CAST(9 AS Uint64)) AS `Uint64Col`,\nJust(Unwrap(CAST(9 AS Uint64))) AS `OptUint64Col`,\nCAST(NULL AS Uint64) AS `NullUint64Col`,\nUnwrap(CAST(1 AS Bool)) AS `BoolCol`,\nJust(Unwrap(CAST(1 AS Bool))) AS `OptBoolCol`,\nCAST(NULL AS Bool) AS `NullBoolCol`,\nUnwrap(CAST(10.5 AS Float)) AS `FloatCol`,\nJust(Unwrap(CAST(10.5 AS Float))) AS `OptFloatCol`,\nCAST(NULL AS Float) AS `NullFloatCol`,\nUnwrap(CAST(11.9 AS Double)) AS `DoubleCol`,\nJust(Unwrap(CAST(11.9 AS Double))) AS `OptDoubleCol`,\nCAST(NULL AS Double) AS `NullDoubleCol`,\nUnwrap(CAST(\"STR_1\" AS String)) AS `StringCol`,\nJust(Unwrap(CAST(\"STR_1\" AS String))) AS `OptStringCol`,\nCAST(NULL AS String) AS `NullStringCol`,\nUnwrap(CAST(\"STR_2\" AS Utf8)) AS `Utf8Col`,\nJust(Unwrap(CAST(\"STR_2\" AS Utf8))) AS `OptUtf8Col`,\nCAST(NULL AS Utf8) AS `NullUtf8Col`,\nUnwrap(CAST(\"\\\"STR_3\\\"\" AS Json)) AS `JsonCol`,\nJust(Unwrap(CAST(\"\\\"STR_3\\\"\" AS Json))) AS `OptJsonCol`,\nCAST(NULL AS Json) AS `NullJsonCol`,\nUnwrap(CAST(CurrentUtcDate() AS Date)) AS `DateCol`,\nJust(Unwrap(CAST(CurrentUtcDate() AS Date))) AS `OptDateCol`,\nCAST(NULL AS Date) AS `NullDateCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime)) AS `DatetimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime))) AS `OptDatetimeCol`,\nCAST(NULL AS Datetime) AS `NullDatetimeCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp)) AS `TimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp))) AS `OptTimestampCol`,\nCAST(NULL AS Timestamp) AS `NullTimestampCol`,\nUnwrap(CAST(CurrentTzDate(1) AS TzDate)) AS `TzDateCol`,\nJust(Unwrap(CAST(CurrentTzDate(1) AS TzDate))) AS `OptTzDateCol`,\nCAST(NULL AS TzDate) AS `NullTzDateCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime)) AS `TzDateTimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime))) AS `OptTzDateTimeCol`,\nCAST(NULL AS TzDateTime) AS `NullTzDateTimeCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp)) AS `TzTimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp))) AS `OptTzTimestampCol`,\nCAST(NULL AS TzTimestamp) AS `NullTzTimestampCol`,\n"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"AsStruct\"},{\"Name\":\"AsList\"},{\"Name\":\"ToFlow\"},{\"Name\":\"ExpandMap\"},{\"Name\":\"FromFlow\"},{\"Name\":\"WideToBlocks\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}"
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataType \'Bool))\n(let $3 (DataType \'Datetime))\n(let $4 (OptionalType $3))\n(let $5 (DataType \'Float))\n(let $6 (DataType \'Int16))\n(let $7 (OptionalType $6))\n(let $8 (DataType \'Int64))\n(let $9 (DataType \'Int8))\n(let $10 (OptionalType $9))\n(let $11 (DataType \'Json))\n(let $12 (OptionalType $11))\n(let $13 (OptionalType $2))\n(let $14 (DataType \'Date))\n(let $15 (OptionalType $14))\n(let $16 (DataType \'Double))\n(let $17 (OptionalType $16))\n(let $18 (OptionalType $5))\n(let $19 (DataType \'Int32))\n(let $20 (OptionalType $19))\n(let $21 (OptionalType $8))\n(let $22 (DataType \'String))\n(let $23 (OptionalType $22))\n(let $24 (DataType \'Timestamp))\n(let $25 (OptionalType $24))\n(let $26 (DataType \'TzDate))\n(let $27 (OptionalType $26))\n(let $28 \'\"NullTzDateTimeCol\")\n(let $29 (DataType \'TzDatetime))\n(let $30 (OptionalType $29))\n(let $31 \'\"NullTzTimestampCol\")\n(let $32 (DataType \'TzTimestamp))\n(let $33 (OptionalType $32))\n(let $34 (DataType \'Uint16))\n(let $35 (OptionalType $34))\n(let $36 (DataType \'Uint32))\n(let $37 (OptionalType $36))\n(let $38 (DataType \'Uint64))\n(let $39 (OptionalType $38))\n(let $40 (DataType \'Uint8))\n(let $41 (OptionalType $40))\n(let $42 (DataType \'Utf8))\n(let $43 (OptionalType $42))\n(let $44 \'\"OptTzTimestampCol\")\n(let $45 (DataSink \'\"s3\" \'\"h2763576556436923985_test_block_insert_enableibucket\"))\n(let $46 \'\"cluster:default_h2763576556436923985_test_block_insert_enableibucket\")\n(let $47 (StructType \'(\'\"BoolCol\" $2) \'(\'\"DateCol\" $14) \'(\'\"DatetimeCol\" $3) \'(\'\"DoubleCol\" $16) \'(\'\"FloatCol\" $5) \'(\'\"Int16Col\" $6) \'(\'\"Int32Col\" $19) \'(\'\"Int64Col\" $8) \'(\'\"Int8Col\" $9) \'(\'\"JsonCol\" $11) \'(\'\"NullBoolCol\" $13) \'(\'\"NullDateCol\" $15) \'(\'\"NullDatetimeCol\" $4) \'(\'\"NullDoubleCol\" $17) \'(\'\"NullFloatCol\" $18) \'(\'\"NullInt16Col\" $7) \'(\'\"NullInt32Col\" $20) \'(\'\"NullInt64Col\" $21) \'(\'\"NullInt8Col\" $10) \'(\'\"NullJsonCol\" $12) \'(\'\"NullStringCol\" $23) \'(\'\"NullTimestampCol\" $25) \'(\'\"NullTzDateCol\" $27) \'($28 $30) \'($31 $33) \'(\'\"NullUint16Col\" $35) \'(\'\"NullUint32Col\" $37) \'(\'\"NullUint64Col\" $39) \'(\'\"NullUint8Col\" $41) \'(\'\"NullUtf8Col\" $43) \'(\'\"OptBoolCol\" $13) \'(\'\"OptDateCol\" $15) \'(\'\"OptDatetimeCol\" $4) \'(\'\"OptDoubleCol\" $17) \'(\'\"OptFloatCol\" $18) \'(\'\"OptInt16Col\" $7) \'(\'\"OptInt32Col\" $20) \'(\'\"OptInt64Col\" $21) \'(\'\"OptInt8Col\" $10) \'(\'\"OptJsonCol\" $12) \'(\'\"OptStringCol\" $23) \'(\'\"OptTimestampCol\" $25) \'(\'\"OptTzDateCol\" $27) \'(\'\"OptTzDateTimeCol\" $30) \'($44 $33) \'(\'\"OptUint16Col\" $35) \'(\'\"OptUint32Col\" $37) \'(\'\"OptUint64Col\" $39) \'(\'\"OptUint8Col\" $41) \'(\'\"OptUtf8Col\" $43) \'(\'\"StringCol\" $22) \'(\'\"TimestampCol\" $24) \'(\'\"TzDateCol\" $26) \'(\'\"TzDateTimeCol\" $29) \'(\'\"TzTimestampCol\" $32) \'(\'\"Uint16Col\" $34) \'(\'\"Uint32Col\" $36) \'(\'\"Uint64Col\" $38) \'(\'\"Uint8Col\" $40) \'(\'\"Utf8Col\" $42)))\n(let $48 (S3SinkSettings \'\"test/\" \'(\'(\'\"multipart\" \'\"true\") \'(\'\"block_output\" \'\"true\")) (SecureParam $46) \'\".parquet\" $47))\n(return (Commit! (DqQuery! $1 \'((DqStage \'() (lambda \'() (block \'(\n  (let $49 (SafeCast (Int32 \'1) $2))\n  (let $50 (Unwrap (SafeCast (String \'\"2025-05-09T18:44:58Z\") $4)))\n  (let $51 (Double \'\"11.9\"))\n  (let $52 (SafeCast (Double \'\"10.5\") $5))\n  (let $53 (Unwrap (SafeCast (Int32 \'\"-3\") $7)))\n  (let $54 (Int32 \'\"4\"))\n  (let $55 (SafeCast (Int32 \'\"-5\") $8))\n  (let $56 (Unwrap (SafeCast (Int32 \'\"2\") $10)))\n  (let $57 (Unwrap (SafeCast (String \'\"\\\"STR_3\\\"\") $12)))\n  (let $58 (String \'\"STR_1\"))\n  (let $59 (Unwrap (SafeCast (String \'\"2025-05-09T18:44:58.678906Z\") $25)))\n  (let $60 (ResourceType \'\"DateTime2.TM\"))\n  (let $61 \'($60 \'\"\" \'1))\n  (let $62 (CallableType \'() \'($26) $61))\n  (let $63 \'(\'(\'\"blocks\") \'(\'\"strict\")))\n  (let $64 (Udf \'\"DateTime2.MakeTzDate\" (Void) (VoidType) \'\"\" $62 (VoidType) \'\"\" $63))\n  (let $65 (TupleType (TupleType $32) (StructType) (TupleType)))\n  (let $66 \'($32 \'\"\" \'1))\n  (let $67 (CallableType \'() \'($60) $66))\n  (let $68 (Udf \'\"DateTime2.Split\" (Void) $65 \'\"\" $67 (VoidType) \'\"\" $63))\n  (let $69 (Apply $64 (Apply $68 (Unwrap (AddTimezone (CurrentUtcTimestamp) (Uint16 \'1))))))\n  (let $70 (Unwrap (SafeCast (String \'\"2025-05-09T21:45:58,Europe/Moscow\") $30)))\n  (let $71 (Unwrap (SafeCast (String \'\"2025-05-09T21:45:58.222886,Europe/Moscow\") $33)))\n  (let $72 (Unwrap (SafeCast (Int32 \'\"7\") $35)))\n  (let $73 (Unwrap (SafeCast (Int32 \'\"8\") $37)))\n  (let $74 (Unwrap (SafeCast (Int32 \'\"9\") $39)))\n  (let $75 (Unwrap (SafeCast (Int32 \'\"6\") $41)))\n  (let $76 (Unwrap (SafeCast (String \'\"STR_2\") $43)))\n  (let $77 (lambda \'($78) (Member $78 \'\"BoolCol\") (Member $78 \'\"DateCol\") (Member $78 \'\"DatetimeCol\") (Member $78 \'\"DoubleCol\") (Member $78 \'\"FloatCol\") (Member $78 \'\"Int16Col\") (Member $78 \'\"Int32Col\") (Member $78 \'\"Int64Col\") (Member $78 \'\"Int8Col\") (Member $78 \'\"JsonCol\") (Member $78 \'\"NullBoolCol\") (Member $78 \'\"NullDateCol\") (Member $78 \'\"NullDatetimeCol\") (Member $78 \'\"NullDoubleCol\") (Member $78 \'\"NullFloatCol\") (Member $78 \'\"NullInt16Col\") (Member $78 \'\"NullInt32Col\") (Member $78 \'\"NullInt64Col\") (Member $78 \'\"NullInt8Col\") (Member $78 \'\"NullJsonCol\") (Member $78 \'\"NullStringCol\") (Member $78 \'\"NullTimestampCol\") (Member $78 \'\"NullTzDateCol\") (Member $78 $28) (Member $78 $31) (Member $78 \'\"NullUint16Col\") (Member $78 \'\"NullUint32Col\") (Member $78 \'\"NullUint64Col\") (Member $78 \'\"NullUint8Col\") (Member $78 \'\"NullUtf8Col\") (Member $78 \'\"OptBoolCol\") (Member $78 \'\"OptDateCol\") (Member $78 \'\"OptDatetimeCol\") (Member $78 \'\"OptDoubleCol\") (Member $78 \'\"OptFloatCol\") (Member $78 \'\"OptInt16Col\") (Member $78 \'\"OptInt32Col\") (Member $78 \'\"OptInt64Col\") (Member $78 \'\"OptInt8Col\") (Member $78 \'\"OptJsonCol\") (Member $78 \'\"OptStringCol\") (Member $78 \'\"OptTimestampCol\") (Member $78 \'\"OptTzDateCol\") (Member $78 \'\"OptTzDateTimeCol\") (Member $78 $44) (Member $78 \'\"OptUint16Col\") (Member $78 \'\"OptUint32Col\") (Member $78 \'\"OptUint64Col\") (Member $78 \'\"OptUint8Col\") (Member $78 \'\"OptUtf8Col\") (Member $78 \'\"StringCol\") (Member $78 \'\"TimestampCol\") (Member $78 \'\"TzDateCol\") (Member $78 \'\"TzDateTimeCol\") (Member $78 \'\"TzTimestampCol\") (Member $78 \'\"Uint16Col\") (Member $78 \'\"Uint32Col\") (Member $78 \'\"Uint64Col\") (Member $78 \'\"Uint8Col\") (Member $78 \'\"Utf8Col\")))\n  (return (WideToBlocks (FromFlow (ExpandMap (ToFlow (AsList (AsStruct \'(\'\"BoolCol\" $49) \'(\'\"DateCol\" (CurrentUtcDate)) \'(\'\"DatetimeCol\" $50) \'(\'\"DoubleCol\" $51) \'(\'\"FloatCol\" $52) \'(\'\"Int16Col\" $53) \'(\'\"Int32Col\" $54) \'(\'\"Int64Col\" $55) \'(\'\"Int8Col\" $56) \'(\'\"JsonCol\" $57) \'(\'\"NullBoolCol\" (Nothing $13)) \'(\'\"NullDateCol\" (Nothing $15)) \'(\'\"NullDatetimeCol\" (Nothing $4)) \'(\'\"NullDoubleCol\" (Nothing $17)) \'(\'\"NullFloatCol\" (Nothing $18)) \'(\'\"NullInt16Col\" (Nothing $7)) \'(\'\"NullInt32Col\" (Nothing $20)) \'(\'\"NullInt64Col\" (Nothing $21)) \'(\'\"NullInt8Col\" (Nothing $10)) \'(\'\"NullJsonCol\" (Nothing $12)) \'(\'\"NullStringCol\" (Nothing $23)) \'(\'\"NullTimestampCol\" (Nothing $25)) \'(\'\"NullTzDateCol\" (Nothing $27)) \'($28 (Nothing $30)) \'($31 (Nothing $33)) \'(\'\"NullUint16Col\" (Nothing $35)) \'(\'\"NullUint32Col\" (Nothing $37)) \'(\'\"NullUint64Col\" (Nothing $39)) \'(\'\"NullUint8Col\" (Nothing $41)) \'(\'\"NullUtf8Col\" (Nothing $43)) \'(\'\"OptBoolCol\" (Just $49)) \'(\'\"OptDateCol\" (Just (CurrentUtcDate))) \'(\'\"OptDatetimeCol\" (Just $50)) \'(\'\"OptDoubleCol\" (Just $51)) \'(\'\"OptFloatCol\" (Just $52)) \'(\'\"OptInt16Col\" (Just $53)) \'(\'\"OptInt32Col\" (Just $54)) \'(\'\"OptInt64Col\" (Just $55)) \'(\'\"OptInt8Col\" (Just $56)) \'(\'\"OptJsonCol\" (Just $57)) \'(\'\"OptStringCol\" (Just $58)) \'(\'\"OptTimestampCol\" (Just $59)) \'(\'\"OptTzDateCol\" (Just $69)) \'(\'\"OptTzDateTimeCol\" (Just $70)) \'($44 (Just $71)) \'(\'\"OptUint16Col\" (Just $72)) \'(\'\"OptUint32Col\" (Just $73)) \'(\'\"OptUint64Col\" (Just $74)) \'(\'\"OptUint8Col\" (Just $75)) \'(\'\"OptUtf8Col\" (Just $76)) \'(\'\"StringCol\" $58) \'(\'\"TimestampCol\" $59) \'(\'\"TzDateCol\" $69) \'(\'\"TzDateTimeCol\" $70) \'(\'\"TzTimestampCol\" $71) \'(\'\"Uint16Col\" $72) \'(\'\"Uint32Col\" $73) \'(\'\"Uint64Col\" $74) \'(\'\"Uint8Col\" $75) \'(\'\"Utf8Col\" $76)))) $77))))\n))) \'() \'((DqSink \'0 $45 $48))))) $45))\n)\n"
  }
}

2025-12-12 13:27:12,752 - DEBUG - root - describe_query: Result: ... (repeated, see above) ...
2025-12-12 13:27:13,263 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudq7r3v4pbl5td5l9"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1765546031
        nanos: 684224000
      }
      modified_at {
        seconds: 1765546031
        nanos: 684224000
      }
      revision: 1
    }
    started_at {
      seconds: 1765546031
      nanos: 977000000
    }
    finished_at {
      seconds: 1765546033
      nanos: 59000000
    }
    execute_mode: RUN
    status: COMPLETED
    last_job_query_revision: 1
    last_job_id: "ptjudq7r3v4p994q1gev-ptqudq7r3v4pbl5td5l9"
    result_expire_at {
      seconds: 1765632431
      nanos: 968642000
    }
    started_by: "root@builtin"
    submitted_at {
      seconds: 1765546031
      nanos: 684224000
    }
  }
  content {
    type: ANALYTICS
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "INSERT INTO `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (FORMAT = \"parquet\") SELECT\nUnwrap(CAST(2 AS Int8)) AS `Int8Col`,\nJust(Unwrap(CAST(2 AS Int8))) AS `OptInt8Col`,\nCAST(NULL AS Int8) AS `NullInt8Col`,\nUnwrap(CAST(-3 AS Int16)) AS `Int16Col`,\nJust(Unwrap(CAST(-3 AS Int16))) AS `OptInt16Col`,\nCAST(NULL AS Int16) AS `NullInt16Col`,\nUnwrap(CAST(4 AS Int32)) AS `Int32Col`,\nJust(Unwrap(CAST(4 AS Int32))) AS `OptInt32Col`,\nCAST(NULL AS Int32) AS `NullInt32Col`,\nUnwrap(CAST(-5 AS Int64)) AS `Int64Col`,\nJust(Unwrap(CAST(-5 AS Int64))) AS `OptInt64Col`,\nCAST(NULL AS Int64) AS `NullInt64Col`,\nUnwrap(CAST(6 AS Uint8)) AS `Uint8Col`,\nJust(Unwrap(CAST(6 AS Uint8))) AS `OptUint8Col`,\nCAST(NULL AS Uint8) AS `NullUint8Col`,\nUnwrap(CAST(7 AS Uint16)) AS `Uint16Col`,\nJust(Unwrap(CAST(7 AS Uint16))) AS `OptUint16Col`,\nCAST(NULL AS Uint16) AS `NullUint16Col`,\nUnwrap(CAST(8 AS Uint32)) AS `Uint32Col`,\nJust(Unwrap(CAST(8 AS Uint32))) AS `OptUint32Col`,\nCAST(NULL AS Uint32) AS `NullUint32Col`,\nUnwrap(CAST(9 AS Uint64)) AS `Uint64Col`,\nJust(Unwrap(CAST(9 AS Uint64))) AS `OptUint64Col`,\nCAST(NULL AS Uint64) AS `NullUint64Col`,\nUnwrap(CAST(1 AS Bool)) AS `BoolCol`,\nJust(Unwrap(CAST(1 AS Bool))) AS `OptBoolCol`,\nCAST(NULL AS Bool) AS `NullBoolCol`,\nUnwrap(CAST(10.5 AS Float)) AS `FloatCol`,\nJust(Unwrap(CAST(10.5 AS Float))) AS `OptFloatCol`,\nCAST(NULL AS Float) AS `NullFloatCol`,\nUnwrap(CAST(11.9 AS Double)) AS `DoubleCol`,\nJust(Unwrap(CAST(11.9 AS Double))) AS `OptDoubleCol`,\nCAST(NULL AS Double) AS `NullDoubleCol`,\nUnwrap(CAST(\"STR_1\" AS String)) AS `StringCol`,\nJust(Unwrap(CAST(\"STR_1\" AS String))) AS `OptStringCol`,\nCAST(NULL AS String) AS `NullStringCol`,\nUnwrap(CAST(\"STR_2\" AS Utf8)) AS `Utf8Col`,\nJust(Unwrap(CAST(\"STR_2\" AS Utf8))) AS `OptUtf8Col`,\nCAST(NULL AS Utf8) AS `NullUtf8Col`,\nUnwrap(CAST(\"\\\"STR_3\\\"\" AS Json)) AS `JsonCol`,\nJust(Unwrap(CAST(\"\\\"STR_3\\\"\" AS Json))) AS `OptJsonCol`,\nCAST(NULL AS Json) AS `NullJsonCol`,\nUnwrap(CAST(CurrentUtcDate() AS Date)) AS `DateCol`,\nJust(Unwrap(CAST(CurrentUtcDate() AS Date))) AS `OptDateCol`,\nCAST(NULL AS Date) AS `NullDateCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime)) AS `DatetimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58Z\" AS Datetime))) AS `OptDatetimeCol`,\nCAST(NULL AS Datetime) AS `NullDatetimeCol`,\nUnwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp)) AS `TimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T18:44:58.678906Z\" AS Timestamp))) AS `OptTimestampCol`,\nCAST(NULL AS Timestamp) AS `NullTimestampCol`,\nUnwrap(CAST(CurrentTzDate(1) AS TzDate)) AS `TzDateCol`,\nJust(Unwrap(CAST(CurrentTzDate(1) AS TzDate))) AS `OptTzDateCol`,\nCAST(NULL AS TzDate) AS `NullTzDateCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime)) AS `TzDateTimeCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58,Europe/Moscow\" AS TzDateTime))) AS `OptTzDateTimeCol`,\nCAST(NULL AS TzDateTime) AS `NullTzDateTimeCol`,\nUnwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp)) AS `TzTimestampCol`,\nJust(Unwrap(CAST(\"2025-05-09T21:45:58.222886,Europe/Moscow\" AS TzTimestamp))) AS `OptTzTimestampCol`,\nCAST(NULL AS TzTimestamp) AS `NullTzTimestampCol`,\n"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"AsStruct\"},{\"Name\":\"AsList\"},{\"Name\":\"ToFlow\"},{\"Name\":\"ExpandMap\"},{\"Name\":\"FromFlow\"},{\"Name\":\"WideToBlocks\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}"
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.96s\",\"count\":1,\"avg\":\"0.96s\",\"max\":\"0.96s\",\"min\":\"0.96s\"},\"EgressBytes\":{\"sum\":15108,\"count\":1,\"avg\":15108,\"max\":15108,\"min\":15108},\"EgressRows\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"MaxMemoryUsage\":{\"sum\":10098880,\"count\":1,\"avg\":10098880,\"max\":10098880,\"min\":10098880},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0}}}"
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataType \'Bool))\n(let $3 (DataType \'Datetime))\n(let $4 (OptionalType $3))\n(let $5 (DataType \'Float))\n(let $6 (DataType \'Int16))\n(let $7 (OptionalType $6))\n(let $8 (DataType \'Int64))\n(let $9 (DataType \'Int8))\n(let $10 (OptionalType $9))\n(let $11 (DataType \'Json))\n(let $12 (OptionalType $11))\n(let $13 (OptionalType $2))\n(let $14 (DataType \'Date))\n(let $15 (OptionalType $14))\n(let $16 (DataType \'Double))\n(let $17 (OptionalType $16))\n(let $18 (OptionalType $5))\n(let $19 (DataType \'Int32))\n(let $20 (OptionalType $19))\n(let $21 (OptionalType $8))\n(let $22 (DataType \'String))\n(let $23 (OptionalType $22))\n(let $24 (DataType \'Timestamp))\n(let $25 (OptionalType $24))\n(let $26 (DataType \'TzDate))\n(let $27 (OptionalType $26))\n(let $28 \'\"NullTzDateTimeCol\")\n(let $29 (DataType \'TzDatetime))\n(let $30 (OptionalType $29))\n(let $31 \'\"NullTzTimestampCol\")\n(let $32 (DataType \'TzTimestamp))\n(let $33 (OptionalType $32))\n(let $34 (DataType \'Uint16))\n(let $35 (OptionalType $34))\n(let $36 (DataType \'Uint32))\n(let $37 (OptionalType $36))\n(let $38 (DataType \'Uint64))\n(let $39 (OptionalType $38))\n(let $40 (DataType \'Uint8))\n(let $41 (OptionalType $40))\n(let $42 (DataType \'Utf8))\n(let $43 (OptionalType $42))\n(let $44 \'\"OptTzTimestampCol\")\n(let $45 (DataSink \'\"s3\" \'\"h2763576556436923985_test_block_insert_enableibucket\"))\n(let $46 \'\"cluster:default_h2763576556436923985_test_block_insert_enableibucket\")\n(let $47 (StructType \'(\'\"BoolCol\" $2) \'(\'\"DateCol\" $14) \'(\'\"DatetimeCol\" $3) \'(\'\"DoubleCol\" $16) \'(\'\"FloatCol\" $5) \'(\'\"Int16Col\" $6) \'(\'\"Int32Col\" $19) \'(\'\"Int64Col\" $8) \'(\'\"Int8Col\" $9) \'(\'\"JsonCol\" $11) \'(\'\"NullBoolCol\" $13) \'(\'\"NullDateCol\" $15) \'(\'\"NullDatetimeCol\" $4) \'(\'\"NullDoubleCol\" $17) \'(\'\"NullFloatCol\" $18) \'(\'\"NullInt16Col\" $7) \'(\'\"NullInt32Col\" $20) \'(\'\"NullInt64Col\" $21) \'(\'\"NullInt8Col\" $10) \'(\'\"NullJsonCol\" $12) \'(\'\"NullStringCol\" $23) \'(\'\"NullTimestampCol\" $25) \'(\'\"NullTzDateCol\" $27) \'($28 $30) \'($31 $33) \'(\'\"NullUint16Col\" $35) \'(\'\"NullUint32Col\" $37) \'(\'\"NullUint64Col\" $39) \'(\'\"NullUint8Col\" $41) \'(\'\"NullUtf8Col\" $43) \'(\'\"OptBoolCol\" $13) \'(\'\"OptDateCol\" $15) \'(\'\"OptDatetimeCol\" $4) \'(\'\"OptDoubleCol\" $17) \'(\'\"OptFloatCol\" $18) \'(\'\"OptInt16Col\" $7) \'(\'\"OptInt32Col\" $20) \'(\'\"OptInt64Col\" $21) \'(\'\"OptInt8Col\" $10) \'(\'\"OptJsonCol\" $12) \'(\'\"OptStringCol\" $23) \'(\'\"OptTimestampCol\" $25) \'(\'\"OptTzDateCol\" $27) \'(\'\"OptTzDateTimeCol\" $30) \'($44 $33) \'(\'\"OptUint16Col\" $35) \'(\'\"OptUint32Col\" $37) \'(\'\"OptUint64Col\" $39) \'(\'\"OptUint8Col\" $41) \'(\'\"OptUtf8Col\" $43) \'(\'\"StringCol\" $22) \'(\'\"TimestampCol\" $24) \'(\'\"TzDateCol\" $26) \'(\'\"TzDateTimeCol\" $29) \'(\'\"TzTimestampCol\" $32) \'(\'\"Uint16Col\" $34) \'(\'\"Uint32Col\" $36) \'(\'\"Uint64Col\" $38) \'(\'\"Uint8Col\" $40) \'(\'\"Utf8Col\" $42)))\n(let $48 (S3SinkSettings \'\"test/\" \'(\'(\'\"multipart\" \'\"true\") \'(\'\"block_output\" \'\"true\")) (SecureParam $46) \'\".parquet\" $47))\n(return (Commit! (DqQuery! $1 \'((DqStage \'() (lambda \'() (block \'(\n  (let $49 (SafeCast (Int32 \'1) $2))\n  (let $50 (Unwrap (SafeCast (String \'\"2025-05-09T18:44:58Z\") $4)))\n  (let $51 (Double \'\"11.9\"))\n  (let $52 (SafeCast (Double \'\"10.5\") $5))\n  (let $53 (Unwrap (SafeCast (Int32 \'\"-3\") $7)))\n  (let $54 (Int32 \'\"4\"))\n  (let $55 (SafeCast (Int32 \'\"-5\") $8))\n  (let $56 (Unwrap (SafeCast (Int32 \'\"2\") $10)))\n  (let $57 (Unwrap (SafeCast (String \'\"\\\"STR_3\\\"\") $12)))\n  (let $58 (String \'\"STR_1\"))\n  (let $59 (Unwrap (SafeCast (String \'\"2025-05-09T18:44:58.678906Z\") $25)))\n  (let $60 (ResourceType \'\"DateTime2.TM\"))\n  (let $61 \'($60 \'\"\" \'1))\n  (let $62 (CallableType \'() \'($26) $61))\n  (let $63 \'(\'(\'\"blocks\") \'(\'\"strict\")))\n  (let $64 (Udf \'\"DateTime2.MakeTzDate\" (Void) (VoidType) \'\"\" $62 (VoidType) \'\"\" $63))\n  (let $65 (TupleType (TupleType $32) (StructType) (TupleType)))\n  (let $66 \'($32 \'\"\" \'1))\n  (let $67 (CallableType \'() \'($60) $66))\n  (let $68 (Udf \'\"DateTime2.Split\" (Void) $65 \'\"\" $67 (VoidType) \'\"\" $63))\n  (let $69 (Apply $64 (Apply $68 (Unwrap (AddTimezone (CurrentUtcTimestamp) (Uint16 \'1))))))\n  (let $70 (Unwrap (SafeCast (String \'\"2025-05-09T21:45:58,Europe/Moscow\") $30)))\n  (let $71 (Unwrap (SafeCast (String \'\"2025-05-09T21:45:58.222886,Europe/Moscow\") $33)))\n  (let $72 (Unwrap (SafeCast (Int32 \'\"7\") $35)))\n  (let $73 (Unwrap (SafeCast (Int32 \'\"8\") $37)))\n  (let $74 (Unwrap (SafeCast (Int32 \'\"9\") $39)))\n  (let $75 (Unwrap (SafeCast (Int32 \'\"6\") $41)))\n  (let $76 (Unwrap (SafeCast (String \'\"STR_2\") $43)))\n  (let $77 (lambda \'($78) (Member $78 \'\"BoolCol\") (Member $78 \'\"DateCol\") (Member $78 \'\"DatetimeCol\") (Member $78 \'\"DoubleCol\") (Member $78 \'\"FloatCol\") (Member $78 \'\"Int16Col\") (Member $78 \'\"Int32Col\") (Member $78 \'\"Int64Col\") (Member $78 \'\"Int8Col\") (Member $78 \'\"JsonCol\") (Member $78 \'\"NullBoolCol\") (Member $78 \'\"NullDateCol\") (Member $78 \'\"NullDatetimeCol\") (Member $78 \'\"NullDoubleCol\") (Member $78 \'\"NullFloatCol\") (Member $78 \'\"NullInt16Col\") (Member $78 \'\"NullInt32Col\") (Member $78 \'\"NullInt64Col\") (Member $78 \'\"NullInt8Col\") (Member $78 \'\"NullJsonCol\") (Member $78 \'\"NullStringCol\") (Member $78 \'\"NullTimestampCol\") (Member $78 \'\"NullTzDateCol\") (Member $78 $28) (Member $78 $31) (Member $78 \'\"NullUint16Col\") (Member $78 \'\"NullUint32Col\") (Member $78 \'\"NullUint64Col\") (Member $78 \'\"NullUint8Col\") (Member $78 \'\"NullUtf8Col\") (Member $78 \'\"OptBoolCol\") (Member $78 \'\"OptDateCol\") (Member $78 \'\"OptDatetimeCol\") (Member $78 \'\"OptDoubleCol\") (Member $78 \'\"OptFloatCol\") (Member $78 \'\"OptInt16Col\") (Member $78 \'\"OptInt32Col\") (Member $78 \'\"OptInt64Col\") (Member $78 \'\"OptInt8Col\") (Member $78 \'\"OptJsonCol\") (Member $78 \'\"OptStringCol\") (Member $78 \'\"OptTimestampCol\") (Member $78 \'\"OptTzDateCol\") (Member $78 \'\"OptTzDateTimeCol\") (Member $78 $44) (Member $78 \'\"OptUint16Col\") (Member $78 \'\"OptUint32Col\") (Member $78 \'\"OptUint64Col\") (Member $78 \'\"OptUint8Col\") (Member $78 \'\"OptUtf8Col\") (Member $78 \'\"StringCol\") (Member $78 \'\"TimestampCol\") (Member $78 \'\"TzDateCol\") (Member $78 \'\"TzDateTimeCol\") (Member $78 \'\"TzTimestampCol\") (Member $78 \'\"Uint16Col\") (Member $78 \'\"Uint32Col\") (Member $78 \'\"Uint64Col\") (Member $78 \'\"Uint8Col\") (Member $78 \'\"Utf8Col\")))\n  (return (WideToBlocks (FromFlow (ExpandMap (ToFlow (AsList (AsStruct \'(\'\"BoolCol\" $49) \'(\'\"DateCol\" (CurrentUtcDate)) \'(\'\"DatetimeCol\" $50) \'(\'\"DoubleCol\" $51) \'(\'\"FloatCol\" $52) \'(\'\"Int16Col\" $53) \'(\'\"Int32Col\" $54) \'(\'\"Int64Col\" $55) \'(\'\"Int8Col\" $56) \'(\'\"JsonCol\" $57) \'(\'\"NullBoolCol\" (Nothing $13)) \'(\'\"NullDateCol\" (Nothing $15)) \'(\'\"NullDatetimeCol\" (Nothing $4)) \'(\'\"NullDoubleCol\" (Nothing $17)) \'(\'\"NullFloatCol\" (Nothing $18)) \'(\'\"NullInt16Col\" (Nothing $7)) \'(\'\"NullInt32Col\" (Nothing $20)) \'(\'\"NullInt64Col\" (Nothing $21)) \'(\'\"NullInt8Col\" (Nothing $10)) \'(\'\"NullJsonCol\" (Nothing $12)) \'(\'\"NullStringCol\" (Nothing $23)) \'(\'\"NullTimestampCol\" (Nothing $25)) \'(\'\"NullTzDateCol\" (Nothing $27)) \'($28 (Nothing $30)) \'($31 (Nothing $33)) \'(\'\"NullUint16Col\" (Nothing $35)) \'(\'\"NullUint32Col\" (Nothing $37)) \'(\'\"NullUint64Col\" (Nothing $39)) \'(\'\"NullUint8Col\" (Nothing $41)) \'(\'\"NullUtf8Col\" (Nothing $43)) \'(\'\"OptBoolCol\" (Just $49)) \'(\'\"OptDateCol\" (Just (CurrentUtcDate))) \'(\'\"OptDatetimeCol\" (Just $50)) \'(\'\"OptDoubleCol\" (Just $51)) \'(\'\"OptFloatCol\" (Just $52)) \'(\'\"OptInt16Col\" (Just $53)) \'(\'\"OptInt32Col\" (Just $54)) \'(\'\"OptInt64Col\" (Just $55)) \'(\'\"OptInt8Col\" (Just $56)) \'(\'\"OptJsonCol\" (Just $57)) \'(\'\"OptStringCol\" (Just $58)) \'(\'\"OptTimestampCol\" (Just $59)) \'(\'\"OptTzDateCol\" (Just $69)) \'(\'\"OptTzDateTimeCol\" (Just $70)) \'($44 (Just $71)) \'(\'\"OptUint16Col\" (Just $72)) \'(\'\"OptUint32Col\" (Just $73)) \'(\'\"OptUint64Col\" (Just $74)) \'(\'\"OptUint8Col\" (Just $75)) \'(\'\"OptUtf8Col\" (Just $76)) \'(\'\"StringCol\" $58) \'(\'\"TimestampCol\" $59) \'(\'\"TzDateCol\" $69) \'(\'\"TzDateTimeCol\" $70) \'(\'\"TzTimestampCol\" $71) \'(\'\"Uint16Col\" $72) \'(\'\"Uint32Col\" $73) \'(\'\"Uint64Col\" $74) \'(\'\"Uint8Col\" $75) \'(\'\"Utf8Col\" $76)))) $77))))\n))) \'() \'((DqSink \'0 $45 $48))))) $45))\n)\n"
  }
}

2025-12-12 13:27:13,277 - DEBUG - root - describe_query: Result: ... (repeated, see above) ...
2025-12-12 13:27:13,277 - DEBUG - root - create_query_impl: Request: content {
  type: ANALYTICS
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            SELECT\n                COUNT(*)\n            FROM `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (\n                FORMAT = \"parquet\",\n                SCHEMA (\n                    Int8Col Int8,\n                )\n            )\n        "
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "c6d0dd2f-3586-4b87-8467-ec7886f2f65d"

2025-12-12 13:27:13,309 - DEBUG - root - create_query_impl: Result: query_id: "ptqudq7r3tjqq8atv18n"

2025-12-12 13:27:13,321 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudq7r3tjqq8atv18n"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1765546033
        nanos: 288365000
      }
      modified_at {
        seconds: 1765546033
        nanos: 288365000
      }
      revision: 1
    }
    execute_mode: RUN
    status: STARTING
    last_job_query_revision: 1
    last_job_id: "ptjudq7r3tjqomov1nd6-ptqudq7r3tjqq8atv18n"
    started_by: "root@builtin"
    submitted_at {
      seconds: 1765546033
      nanos: 288365000
    }
  }
  content {
    type: ANALYTICS
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "\n            SELECT\n                COUNT(*)\n            FROM `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (\n                FORMAT = \"parquet\",\n                SCHEMA (\n                    Int8Col Int8,\n                )\n            )\n        "
    syntax: YQL_V1
  }
}

2025-12-12 13:27:13,852 - DEBUG - root - describe_query: Result: ... (repeated, see above) ...
2025-12-12 13:27:14,367 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudq7r3tjqq8atv18n"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1765546033
        nanos: 288365000
      }
      modified_at {
        seconds: 1765546033
        nanos: 288365000
      }
      revision: 1
    }
    started_at {
      seconds: 1765546033
      nanos: 987000000
    }
    finished_at {
      seconds: 1765546034
      nanos: 202000000
    }
    execute_mode: RUN
    status: COMPLETED
    last_job_query_revision: 1
    last_job_id: "ptjudq7r3tjqomov1nd6-ptqudq7r3tjqq8atv18n"
    result_expire_at {
      seconds: 1765632433
      nanos: 978060000
    }
    started_by: "root@builtin"
    submitted_at {
      seconds: 1765546033
      nanos: 288365000
    }
  }
  content {
    type: ANALYTICS
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "\n            SELECT\n                COUNT(*)\n            FROM `h2763576556436923985_test_block_insert_enableibucket`.`/test/` WITH (\n                FORMAT = \"parquet\",\n                SCHEMA (\n                    Int8Col Int8,\n                )\n            )\n        "
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":13,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideBlockWrap\"},{\"Name\":\"FromFlow\"},{\"Name\":\"WideFromBlocks\"},{\"Name\":\"ToFlow\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"DqPhyLength\"}]}},{\"Id\":11,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Condense\"}]},\"DependsOn\":[13]},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"AsList\"},{\"Name\":\"Iterator\"},{\"Name\":\"FlatMap\"}]},\"DependsOn\":[11]},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":4,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":13,\"level\":1,\"name\":\"DqStage #13\",\"type\":\"op\"},{\"id\":11,\"level\":2,\"name\":\"DqStage #11\",\"type\":\"op\"},{\"id\":8,\"level\":3,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":4,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":5,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":6,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":13,\"target\":11},{\"source\":11,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  statistics {
    json: "{\"Precompute=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.12s\",\"count\":2,\"avg\":\"60ms\",\"max\":\"81ms\",\"min\":\"40ms\"},\"IngressBytes\":{\"sum\":15108,\"count\":1,\"avg\":15108,\"max\":15108,\"min\":15108},\"IngressRows\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"InputBytes\":{\"sum\":3,\"count\":1,\"avg\":3,\"max\":3,\"min\":3},\"InputRows\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"OutputBytes\":{\"sum\":6,\"count\":2,\"avg\":3,\"max\":3,\"min\":3},\"OutputRows\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"ResultBytes\":{\"sum\":3,\"count\":1,\"avg\":3,\"max\":3,\"min\":3},\"ResultRows\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"MaxMemoryUsage\":{\"sum\":262144,\"count\":2,\"avg\":131072,\"max\":131072,\"min\":131072},\"IngressQueuedBytes\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0}},\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"23ms\",\"count\":2,\"avg\":\"11ms\",\"max\":\"21ms\",\"min\":\"2ms\"},\"InputBytes\":{\"sum\":3,\"count\":1,\"avg\":3,\"max\":3,\"min\":3},\"InputRows\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"OutputBytes\":{\"sum\":6,\"count\":2,\"avg\":3,\"max\":3,\"min\":3},\"OutputRows\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"ResultBytes\":{\"sum\":3,\"count\":1,\"avg\":3,\"max\":3,\"min\":3},\"ResultRows\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"MaxMemoryUsage\":{\"sum\":327680,\"count\":2,\"avg\":163840,\"max\":196608,\"min\":131072},\"IngressQueuedBytes\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0}}}"
  }
  result_set_meta {
    column {
      name: "column0"
      type {
        type_id: UINT64
      }
    }
    rows_count: 1
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 \'\"h2763576556436923985_test_block_insert_enableibucket\")\n(let $4 (DataSource \'\"s3\" $3))\n(let $5 \'\"Paths {\\n  Name: \\\"test\\\"\\n  Children {\\n    Name: \\\"ptjudq7r3v4p994q1gev_0_wxeijZWt4keS_re7PWutBE59lK47NaDe.parquet\\\"\\n    Size: 15108\\n    Read: true\\n  }\\n  IsDirectory: true\\n}\\n\")\n(let $6 (Bool \'\"true\"))\n(let $7 \'\"cluster:default_h2763576556436923985_test_block_insert_enableibucket\")\n(let $8 (S3ParseSettings world \'(\'((String $5) $6 (AsStruct))) (SecureParam $7) \'\"\" \'\"/test/ \" \'\"parquet\" (StructType) (lambda \'($15) $6) \'()))\n(let $9 (DqStage \'((DqSource $4 $8)) (lambda \'($16) (DqPhyLength (NarrowMap (ToFlow (WideFromBlocks (FromFlow (DqSourceWideBlockWrap $16 $4 (StructType) \'(\'(\'format \'\"parquet\")))))) (lambda \'() (AsStruct))) \'\"_dq_agg_cnt\")) \'(\'(\'\"_logical_id\" \'200379))))\n(let $10 (DqStage \'((DqCnUnionAll (TDqOutput $9 \'\"0\"))) (lambda \'($17) (Condense $17 (Uint64 \'\"0\") (lambda \'($18 $19) (Bool \'false)) (lambda \'($20 $21) (AggrAdd $21 (Member $20 \'\"_dq_agg_cnt\"))))) \'(\'(\'\"_logical_id\" \'200404))))\n(let $11 (DqStage \'((DqPhyPrecompute (DqCnValue (TDqOutput $10 \'\"0\")))) (lambda \'($22) (FlatMap (Iterator (AsList $22)) (lambda \'($23) (Just (AsStruct \'(\'\"column0\" $23)))))) \'(\'(\'\"_logical_id\" \'200455))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($24) $24) \'(\'(\'\"_logical_id\" \'200535))))\n(let $13 \'(\'(\'type) \'(\'autoref) \'(\'columns \'(\'\"column0\"))))\n(let $14 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $12 \'\"0\") \'()) $13 \'\"dq\"))\n(return (Commit! (Commit! $14 $2) (DataSink \'\"s3\" $3)))\n)\n"
  }
}

2025-12-12 13:27:14,399 - INFO - ya.test - pytest_runtest_teardown: Test teardown
