2025-11-11 15:21:57,668 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-11-11 15:21:57,669 - INFO - ya.test - pytest_runtest_setup: test_mapping_with_nodes
2025-11-11 15:21:57,669 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-11-11 15:21:57,669 - INFO - ya.test - pytest_runtest_setup: Test setup
2025-11-11 15:21:57,671 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/2475
2025-11-11 15:21:57,673 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/2596
2025-11-11 15:21:57,830 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd
2025-11-11 15:21:57,831 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/64480
2025-11-11 15:21:57,833 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/2342
2025-11-11 15:21:57,938 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd
2025-11-11 15:21:57,939 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/3727
2025-11-11 15:21:58,048 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd
2025-11-11 15:21:58,049 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/1654
2025-11-11 15:21:58,050 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/64932
2025-11-11 15:21:58,051 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/23226
2025-11-11 15:21:58,052 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-11 15:21:58,069 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-11 15:21:58,070 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-11 15:21:58,086 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-11 15:21:58,087 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, db86ae4b-598b-46f5-a6eb-d7e45231b478, localhost:8186): creating call state
2025-11-11 15:21:58,087 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, db86ae4b-598b-46f5-a6eb-d7e45231b478, localhost:8186): request = { database: "local" }
2025-11-11 15:21:58,093 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, db86ae4b-598b-46f5-a6eb-d7e45231b478, localhost:8186): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-ox5xijdfoi.auto.internal" port: 8186 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-11 15:21:58,094 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-ox5xijdfoi.auto.internal:8186, location 1, ssl: False>]>
2025-11-11 15:21:58,094 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-11 15:21:58,104 - INFO - ydb.connection - close: Closing channel for endpoint localhost:8186
2025-11-11 15:21:58,106 - DEBUG - ydb.table.SessionPool - subscribe: Active session queue is empty, subscribe waiter for a session
2025-11-11 15:21:58,107 - DEBUG - ydb.table.SessionPool - subscribe: Subscribe waiter <Future at 0x7bf91f007a30 state=pending>
2025-11-11 15:21:58,107 - DEBUG - ydb.table.SessionPool - subscribe: Session pool is not large enough (active_count < size: 0 < 1). will create a new session.
2025-11-11 15:21:58,108 - DEBUG - ydb.table.SessionPool - _create: Created session <ydb.table.Session object at 0x7bf91f024cb0>
2025-11-11 15:21:58,108 - DEBUG - ydb.table.SessionPool - _prepare: Preparing session <ydb.table.Session object at 0x7bf91f024cb0>
2025-11-11 15:21:58,109 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateSession, 8677dcc9-6539-4c63-9e4d-9b526ccf0057, ghrun-ox5xijdfoi.auto.internal:8186): creating call state
2025-11-11 15:21:58,109 - DEBUG - ydb.connection - _log_request: RpcState(CreateSession, 8677dcc9-6539-4c63-9e4d-9b526ccf0057, ghrun-ox5xijdfoi.auto.internal:8186): request = { operation_params { operation_timeout { seconds: 3 } cancel_after { seconds: 3 } } }
2025-11-11 15:21:58,118 - DEBUG - ydb.connection - _on_response_callback: RpcState(CreateSession, 8677dcc9-6539-4c63-9e4d-9b526ccf0057, ghrun-ox5xijdfoi.auto.internal:8186): on response callback started
2025-11-11 15:21:58,119 - DEBUG - ydb.connection - _log_response: RpcState(CreateSession, 8677dcc9-6539-4c63-9e4d-9b526ccf0057, ghrun-ox5xijdfoi.auto.internal:8186): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Table.CreateSessionResult] { session_id: "ydb://session/3?node_id=1&id=NDI3NmY3YTUtYjRhNjMxZmUtYzAzNGJlYmQtYTljYTRmNzE=" } } } }
2025-11-11 15:21:58,120 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7bf91f024cb0>
2025-11-11 15:21:58,121 - DEBUG - ydb.table.SessionPool - put: Replying to waiter with a session <ydb.table.Session object at 0x7bf91f024cb0>
2025-11-11 15:21:58,122 - DEBUG - ydb.connection - _on_response_callback: RpcState(CreateSession, 8677dcc9-6539-4c63-9e4d-9b526ccf0057, ghrun-ox5xijdfoi.auto.internal:8186): on response callback success
2025-11-11 15:21:58,124 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateTable, fbcaca34-88a4-44a3-9643-46fc92d9dd10, ghrun-ox5xijdfoi.auto.internal:8186): creating call state
2025-11-11 15:21:58,126 - DEBUG - ydb.connection - _log_request: RpcState(CreateTable, fbcaca34-88a4-44a3-9643-46fc92d9dd10, ghrun-ox5xijdfoi.auto.internal:8186): request = { session_id: "ydb://session/3?node_id=1&id=NDI3NmY3YTUtYjRhNjMxZmUtYzAzNGJlYmQtYTljYTRmNzE=" path: "local/DbPoolStorage_aa2312f2-d645-4cfa-b7e9-c8caf94f2076/tenants" columns { name: "tenant" type { optional_type { item { type_id: STRING } } } } columns { name: "vtenant" type { optional_type { item { type_id: STRING } } } } columns { name: "common" type { optional_type { item { type_id: BOOL } } } } columns { name: "state" type { optional_type { item { type_id: UINT32 } } } } columns { name: "state_time" type { optional_type { item { type_id: TIMESTAMP } } } } primary_key: "tenant" operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-11 15:21:58,227 - DEBUG - ydb.connection - _log_response: RpcState(CreateTable, fbcaca34-88a4-44a3-9643-46fc92d9dd10, ghrun-ox5xijdfoi.auto.internal:8186): response = { operation { ready: true status: SUCCESS } }
2025-11-11 15:21:58,229 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7bf91f024cb0>
2025-11-11 15:21:58,230 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateTable, 9e8d5354-5ab3-4215-90fe-a0c566084340, ghrun-ox5xijdfoi.auto.internal:8186): creating call state
2025-11-11 15:21:58,241 - DEBUG - ydb.connection - _log_request: RpcState(CreateTable, 9e8d5354-5ab3-4215-90fe-a0c566084340, ghrun-ox5xijdfoi.auto.internal:8186): request = { session_id: "ydb://session/3?node_id=1&id=NDI3NmY3YTUtYjRhNjMxZmUtYzAzNGJlYmQtYTljYTRmNzE=" path: "local/DbPoolStorage_aa2312f2-d645-4cfa-b7e9-c8caf94f2076/mappings" columns { name: "subject_type" type { optional_type { item { type_id: STRING } } } } columns { name: "subject_id" type { optional_type { item { type_id: STRING } } } } columns { name: "vtenant" type { optional_type { item { type_id: STRING } } } } columns { name: "node" type { optional_type { item { type_id: STRING } } } } primary_key: "subject_type" primary_key: "subject_id" operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-11 15:21:58,353 - DEBUG - ydb.connection - _log_response: RpcState(CreateTable, 9e8d5354-5ab3-4215-90fe-a0c566084340, ghrun-ox5xijdfoi.auto.internal:8186): response = { operation { ready: true status: SUCCESS } }
2025-11-11 15:21:58,354 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7bf91f024cb0>
2025-11-11 15:21:58,356 - DEBUG - ydb.connection - _prepare_call: RpcState(ExecuteDataQuery, 46114baa-d777-46f0-80f4-c017527c2634, ghrun-ox5xijdfoi.auto.internal:8186): creating call state
2025-11-11 15:21:58,357 - DEBUG - ydb.connection - _log_request: RpcState(ExecuteDataQuery, 46114baa-d777-46f0-80f4-c017527c2634, ghrun-ox5xijdfoi.auto.internal:8186): request = { session_id: "ydb://session/3?node_id=1&id=NDI3NmY3YTUtYjRhNjMxZmUtYzAzNGJlYmQtYTljYTRmNzE=" tx_control { begin_tx { serializable_read_write { } } commit_tx: true } query { yql_text: "--!syntax_v1\n            PRAGMA TablePathPrefix(\"local/DbPoolStorage_aa2312f2-d645-4cfa-b7e9-c8caf94f2076\");\n            UPSERT INTO tenants (tenant, vtenant, common, state, state_time) values(\"/alpha\", \"alpha\", true, 0, CurrentUtcTimestamp());\n                UPSERT INTO tenants (tenant, vtenant, common, state, state_time) values(\"/beta\", \"beta\", true, 0, CurrentUtcTimestamp());\n                UPSERT INTO mappings (subject_type, subject_id, vtenant, node) values (\"cloud\", \"a_cloud\", \"alpha\", NULL);\n                UPSERT INTO mappings (subject_type, subject_id, vtenant, node) values (\"cloud\", \"b_cloud\", \"beta\", \"1 \");\n                UPSERT INTO mappings (subject_type, subject_id, vtenant, node) values (\"cloud\", \"c_cloud\", \"beta\", \" 2\");\n                UPSERT INTO mappings (subject_type, subject_id, vtenant, node) values (\"cloud\", \"d_cloud\", \"beta\", \" 1 - 2 \");\n                " } operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-11 15:21:58,870 - DEBUG - ydb.connection - _log_response: RpcState(ExecuteDataQuery, 46114baa-d777-46f0-80f4-c017527c2634, ghrun-ox5xijdfoi.auto.internal:8186): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Table.ExecuteQueryResult] { tx_meta { } } } } }
2025-11-11 15:21:58,871 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7bf91f024cb0>
2025-11-11 15:21:58,995 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd
2025-11-11 15:21:58,997 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/1233
2025-11-11 15:21:59,005 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/24931
2025-11-11 15:21:59,006 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/21772
2025-11-11 15:21:59,007 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/cp/kikimr_configs"
2025-11-11 15:21:59,008 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/cp --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/cp/node_1/logfile_5p_xmfyg.log --grpc-port=23226 --mon-port=1233 --ic-port=64480
2025-11-11 15:21:59,011 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/cp/kikimr_configs"
2025-11-11 15:21:59,011 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/cp --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/cp/node_1/logfile_5p_xmfyg.log --grpc-port=23226 --mon-port=1233 --ic-port=64480
2025-11-11 15:21:59,014 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/cp/kikimr_configs/config.yaml', '--node=1', '--tenant=/cp', '--node-kind=yq', '--log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/cp/node_1/logfile_5p_xmfyg.log', '--grpc-port=23226', '--mon-port=1233', '--ic-port=64480')' in '/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/cp/node_1' (no wait)
2025-11-11 15:21:59,018 - DEBUG - ya.test - execute: Command pid: 550008
2025-11-11 15:21:59,020 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:23226/1
2025-11-11 15:21:59,023 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.8
2025-11-11 15:21:59,024 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.8
2025-11-11 15:21:59,025 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-11 15:21:59,044 - DEBUG - ya.test - execute: Command pid: 550011
2025-11-11 15:22:00,011 - DEBUG - ya.test - _save_outputs: Command (pid 550011) rc: 0
2025-11-11 15:22:00,012 - DEBUG - ya.test - _save_outputs: Command (pid 550011) elapsed time (sec): 0.9653575420379639
2025-11-11 15:22:00,013 - DEBUG - ya.test - _save_outputs: Command (pid 550011) idrss: 0
2025-11-11 15:22:00,013 - DEBUG - ya.test - _save_outputs: Command (pid 550011) inblock: 0
2025-11-11 15:22:00,013 - DEBUG - ya.test - _save_outputs: Command (pid 550011) isrss: 0
2025-11-11 15:22:00,014 - DEBUG - ya.test - _save_outputs: Command (pid 550011) ixrss: 0
2025-11-11 15:22:00,014 - DEBUG - ya.test - _save_outputs: Command (pid 550011) majflt: 0
2025-11-11 15:22:00,015 - DEBUG - ya.test - _save_outputs: Command (pid 550011) maxrss: 673544
2025-11-11 15:22:00,015 - DEBUG - ya.test - _save_outputs: Command (pid 550011) minflt: 45419
2025-11-11 15:22:00,015 - DEBUG - ya.test - _save_outputs: Command (pid 550011) msgrcv: 0
2025-11-11 15:22:00,016 - DEBUG - ya.test - _save_outputs: Command (pid 550011) msgsnd: 0
2025-11-11 15:22:00,016 - DEBUG - ya.test - _save_outputs: Command (pid 550011) nivcsw: 184
2025-11-11 15:22:00,017 - DEBUG - ya.test - _save_outputs: Command (pid 550011) nsignals: 0
2025-11-11 15:22:00,017 - DEBUG - ya.test - _save_outputs: Command (pid 550011) nswap: 0
2025-11-11 15:22:00,018 - DEBUG - ya.test - _save_outputs: Command (pid 550011) nvcsw: 14
2025-11-11 15:22:00,018 - DEBUG - ya.test - _save_outputs: Command (pid 550011) oublock: 8
2025-11-11 15:22:00,018 - DEBUG - ya.test - _save_outputs: Command (pid 550011) stime: 0.182808
2025-11-11 15:22:00,019 - DEBUG - ya.test - _save_outputs: Command (pid 550011) utime: 0.556564
2025-11-11 15:22:00,019 - DEBUG - ya.test - _save_outputs: Command (pid 550011) wtime: 0.986
2025-11-11 15:22:00,020 - DEBUG - ya.test - _save_outputs: Command (pid 550011) output:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-ox5xijdfoi
    Host information: 
        Linux ghrun-ox5xijdfoi 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9695656278/bin/clang++
    Compiler version: 
        clang version 20.1.2
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9695656278/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -fsanitize=address -Daddress_sanitizer_enabled -fno-omit-frame-pointer -fsanitize-blacklist=/home/runner/actions_runner/_work/ydb/ydb/build/sanitize-blacklist.txt -fno-sanitize-link-runtime -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-11 15:22:00,021 - DEBUG - ya.test - _save_outputs: Command (pid 550011) errors:

2025-11-11 15:22:00,022 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a
2025-11-11 15:22:00,023 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-11-11 15:22:00,087 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd
2025-11-11 15:22:00,089 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/4236
2025-11-11 15:22:00,089 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/1825
2025-11-11 15:22:00,090 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/26046
2025-11-11 15:22:00,091 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/9320
2025-11-11 15:22:00,093 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/alpha/kikimr_configs"
2025-11-11 15:22:00,093 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/alpha --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/alpha/node_1/logfile_ifxvqd30.log --grpc-port=4236 --mon-port=1825 --ic-port=3727
2025-11-11 15:22:00,094 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/alpha/kikimr_configs"
2025-11-11 15:22:00,094 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/alpha --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/alpha/node_1/logfile_ifxvqd30.log --grpc-port=4236 --mon-port=1825 --ic-port=3727
2025-11-11 15:22:00,096 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/alpha/kikimr_configs/config.yaml', '--node=1', '--tenant=/alpha', '--node-kind=yq', '--log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/alpha/node_1/logfile_ifxvqd30.log', '--grpc-port=4236', '--mon-port=1825', '--ic-port=3727')' in '/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/alpha/node_1' (no wait)
2025-11-11 15:22:00,108 - DEBUG - ya.test - execute: Command pid: 550102
2025-11-11 15:22:00,109 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:4236/1
2025-11-11 15:22:00,111 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.9
2025-11-11 15:22:00,113 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.9
2025-11-11 15:22:00,113 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-11 15:22:00,115 - DEBUG - ya.test - execute: Command pid: 550105
2025-11-11 15:22:00,947 - DEBUG - ya.test - _save_outputs: Command (pid 550105) rc: 0
2025-11-11 15:22:00,947 - DEBUG - ya.test - _save_outputs: Command (pid 550105) elapsed time (sec): 0.8307332992553711
2025-11-11 15:22:00,948 - DEBUG - ya.test - _save_outputs: Command (pid 550105) idrss: 0
2025-11-11 15:22:00,948 - DEBUG - ya.test - _save_outputs: Command (pid 550105) inblock: 0
2025-11-11 15:22:00,949 - DEBUG - ya.test - _save_outputs: Command (pid 550105) isrss: 0
2025-11-11 15:22:00,949 - DEBUG - ya.test - _save_outputs: Command (pid 550105) ixrss: 0
2025-11-11 15:22:00,949 - DEBUG - ya.test - _save_outputs: Command (pid 550105) majflt: 0
2025-11-11 15:22:00,949 - DEBUG - ya.test - _save_outputs: Command (pid 550105) maxrss: 677376
2025-11-11 15:22:00,950 - DEBUG - ya.test - _save_outputs: Command (pid 550105) minflt: 45279
2025-11-11 15:22:00,950 - DEBUG - ya.test - _save_outputs: Command (pid 550105) msgrcv: 0
2025-11-11 15:22:00,951 - DEBUG - ya.test - _save_outputs: Command (pid 550105) msgsnd: 0
2025-11-11 15:22:00,951 - DEBUG - ya.test - _save_outputs: Command (pid 550105) nivcsw: 174
2025-11-11 15:22:00,951 - DEBUG - ya.test - _save_outputs: Command (pid 550105) nsignals: 0
2025-11-11 15:22:00,952 - DEBUG - ya.test - _save_outputs: Command (pid 550105) nswap: 0
2025-11-11 15:22:00,952 - DEBUG - ya.test - _save_outputs: Command (pid 550105) nvcsw: 14
2025-11-11 15:22:00,952 - DEBUG - ya.test - _save_outputs: Command (pid 550105) oublock: 8
2025-11-11 15:22:00,953 - DEBUG - ya.test - _save_outputs: Command (pid 550105) stime: 0.20437
2025-11-11 15:22:00,953 - DEBUG - ya.test - _save_outputs: Command (pid 550105) utime: 0.5307649999999999
2025-11-11 15:22:00,954 - DEBUG - ya.test - _save_outputs: Command (pid 550105) wtime: 0.833
2025-11-11 15:22:00,954 - DEBUG - ya.test - _save_outputs: Command (pid 550105) output:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-ox5xijdfoi
    Host information: 
        Linux ghrun-ox5xijdfoi 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9695656278/bin/clang++
    Compiler version: 
        clang version 20.1.2
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9695656278/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -fsanitize=address -Daddress_sanitizer_enabled -fno-omit-frame-pointer -fsanitize-blacklist=/home/runner/actions_runner/_work/ydb/ydb/build/sanitize-blacklist.txt -fno-sanitize-link-runtime -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-11 15:22:00,955 - DEBUG - ya.test - _save_outputs: Command (pid 550105) errors:

2025-11-11 15:22:00,955 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a
2025-11-11 15:22:00,958 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-11-11 15:22:01,018 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd
2025-11-11 15:22:01,018 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/15118
2025-11-11 15:22:01,019 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/8836
2025-11-11 15:22:01,020 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/17927
2025-11-11 15:22:01,020 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/13817
2025-11-11 15:22:01,021 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/kikimr_configs"
2025-11-11 15:22:01,022 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/beta --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_1/logfile_rey5e3ms.log --grpc-port=15118 --mon-port=8836 --ic-port=1654
2025-11-11 15:22:01,023 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd
2025-11-11 15:22:01,023 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/20562
2025-11-11 15:22:01,024 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/13696
2025-11-11 15:22:01,025 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/8250
2025-11-11 15:22:01,025 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/12304
2025-11-11 15:22:01,026 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/kikimr_configs"
2025-11-11 15:22:01,027 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=2 --tenant=/beta --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_2/logfile_zp8l2n0i.log --grpc-port=20562 --mon-port=13696 --ic-port=64932
2025-11-11 15:22:01,028 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/kikimr_configs"
2025-11-11 15:22:01,028 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/beta --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_1/logfile_rey5e3ms.log --grpc-port=15118 --mon-port=8836 --ic-port=1654
2025-11-11 15:22:01,030 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/kikimr_configs/config.yaml', '--node=1', '--tenant=/beta', '--node-kind=yq', '--log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_1/logfile_rey5e3ms.log', '--grpc-port=15118', '--mon-port=8836', '--ic-port=1654')' in '/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_1' (no wait)
2025-11-11 15:22:01,053 - DEBUG - ya.test - execute: Command pid: 550303
2025-11-11 15:22:01,054 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:15118/1
2025-11-11 15:22:01,056 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.10
2025-11-11 15:22:01,058 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.10
2025-11-11 15:22:01,058 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-11 15:22:01,080 - DEBUG - ya.test - execute: Command pid: 550306
2025-11-11 15:22:02,009 - DEBUG - ya.test - _save_outputs: Command (pid 550306) rc: 0
2025-11-11 15:22:02,009 - DEBUG - ya.test - _save_outputs: Command (pid 550306) elapsed time (sec): 0.9269466400146484
2025-11-11 15:22:02,010 - DEBUG - ya.test - _save_outputs: Command (pid 550306) idrss: 0
2025-11-11 15:22:02,010 - DEBUG - ya.test - _save_outputs: Command (pid 550306) inblock: 0
2025-11-11 15:22:02,011 - DEBUG - ya.test - _save_outputs: Command (pid 550306) isrss: 0
2025-11-11 15:22:02,011 - DEBUG - ya.test - _save_outputs: Command (pid 550306) ixrss: 0
2025-11-11 15:22:02,011 - DEBUG - ya.test - _save_outputs: Command (pid 550306) majflt: 0
2025-11-11 15:22:02,012 - DEBUG - ya.test - _save_outputs: Command (pid 550306) maxrss: 681740
2025-11-11 15:22:02,012 - DEBUG - ya.test - _save_outputs: Command (pid 550306) minflt: 45327
2025-11-11 15:22:02,012 - DEBUG - ya.test - _save_outputs: Command (pid 550306) msgrcv: 0
2025-11-11 15:22:02,013 - DEBUG - ya.test - _save_outputs: Command (pid 550306) msgsnd: 0
2025-11-11 15:22:02,013 - DEBUG - ya.test - _save_outputs: Command (pid 550306) nivcsw: 155
2025-11-11 15:22:02,013 - DEBUG - ya.test - _save_outputs: Command (pid 550306) nsignals: 0
2025-11-11 15:22:02,014 - DEBUG - ya.test - _save_outputs: Command (pid 550306) nswap: 0
2025-11-11 15:22:02,014 - DEBUG - ya.test - _save_outputs: Command (pid 550306) nvcsw: 14
2025-11-11 15:22:02,014 - DEBUG - ya.test - _save_outputs: Command (pid 550306) oublock: 8
2025-11-11 15:22:02,015 - DEBUG - ya.test - _save_outputs: Command (pid 550306) stime: 0.20049899999999998
2025-11-11 15:22:02,015 - DEBUG - ya.test - _save_outputs: Command (pid 550306) utime: 0.5430309999999999
2025-11-11 15:22:02,015 - DEBUG - ya.test - _save_outputs: Command (pid 550306) wtime: 0.95
2025-11-11 15:22:02,016 - DEBUG - ya.test - _save_outputs: Command (pid 550306) output:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-ox5xijdfoi
    Host information: 
        Linux ghrun-ox5xijdfoi 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9695656278/bin/clang++
    Compiler version: 
        clang version 20.1.2
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9695656278/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -fsanitize=address -Daddress_sanitizer_enabled -fno-omit-frame-pointer -fsanitize-blacklist=/home/runner/actions_runner/_work/ydb/ydb/build/sanitize-blacklist.txt -fno-sanitize-link-runtime -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-11 15:22:02,025 - DEBUG - ya.test - _save_outputs: Command (pid 550306) errors:

2025-11-11 15:22:02,025 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a
2025-11-11 15:22:02,026 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/kikimr_configs"
2025-11-11 15:22:02,026 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=2 --tenant=/beta --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_2/logfile_zp8l2n0i.log --grpc-port=20562 --mon-port=13696 --ic-port=64932
2025-11-11 15:22:02,033 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/kikimr_configs/config.yaml', '--node=2', '--tenant=/beta', '--node-kind=yq', '--log-file-name=/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_2/logfile_zp8l2n0i.log', '--grpc-port=20562', '--mon-port=13696', '--ic-port=64932')' in '/home/runner/.ya/build/build_root/po9u/0010f6/ydb/tests/fq/multi_plane/test-results/py3test/testing_out_stuff/test_dispatch/testing_out_stuff/test_dispatch.py.TestMapping.test_mapping_with_nodes/beta/node_2' (no wait)
2025-11-11 15:22:02,206 - DEBUG - ya.test - execute: Command pid: 550449
2025-11-11 15:22:02,207 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:20562/2
2025-11-11 15:22:02,209 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.11
2025-11-11 15:22:02,210 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.11
2025-11-11 15:22:02,210 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/po9u/0010f6/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-11 15:22:02,213 - DEBUG - ya.test - execute: Command pid: 550452
2025-11-11 15:22:03,084 - DEBUG - ya.test - _save_outputs: Command (pid 550452) rc: 0
2025-11-11 15:22:03,085 - DEBUG - ya.test - _save_outputs: Command (pid 550452) elapsed time (sec): 0.8705170154571533
2025-11-11 15:22:03,085 - DEBUG - ya.test - _save_outputs: Command (pid 550452) idrss: 0
2025-11-11 15:22:03,086 - DEBUG - ya.test - _save_outputs: Command (pid 550452) inblock: 0
2025-11-11 15:22:03,086 - DEBUG - ya.test - _save_outputs: Command (pid 550452) isrss: 0
2025-11-11 15:22:03,086 - DEBUG - ya.test - _save_outputs: Command (pid 550452) ixrss: 0
2025-11-11 15:22:03,087 - DEBUG - ya.test - _save_outputs: Command (pid 550452) majflt: 0
2025-11-11 15:22:03,087 - DEBUG - ya.test - _save_outputs: Command (pid 550452) maxrss: 682960
2025-11-11 15:22:03,087 - DEBUG - ya.test - _save_outputs: Command (pid 550452) minflt: 45418
2025-11-11 15:22:03,087 - DEBUG - ya.test - _save_outputs: Command (pid 550452) msgrcv: 0
2025-11-11 15:22:03,088 - DEBUG - ya.test - _save_outputs: Command (pid 550452) msgsnd: 0
2025-11-11 15:22:03,094 - DEBUG - ya.test - _save_outputs: Command (pid 550452) nivcsw: 156
2025-11-11 15:22:03,094 - DEBUG - ya.test - _save_outputs: Command (pid 550452) nsignals: 0
2025-11-11 15:22:03,095 - DEBUG - ya.test - _save_outputs: Command (pid 550452) nswap: 0
2025-11-11 15:22:03,095 - DEBUG - ya.test - _save_outputs: Command (pid 550452) nvcsw: 14
2025-11-11 15:22:03,095 - DEBUG - ya.test - _save_outputs: Command (pid 550452) oublock: 8
2025-11-11 15:22:03,096 - DEBUG - ya.test - _save_outputs: Command (pid 550452) stime: 0.239092
2025-11-11 15:22:03,096 - DEBUG - ya.test - _save_outputs: Command (pid 550452) utime: 0.517231
2025-11-11 15:22:03,096 - DEBUG - ya.test - _save_outputs: Command (pid 550452) wtime: 0.873
2025-11-11 15:22:03,097 - DEBUG - ya.test - _save_outputs: Command (pid 550452) output:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-ox5xijdfoi
    Host information: 
        Linux ghrun-ox5xijdfoi 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9695656278/bin/clang++
    Compiler version: 
        clang version 20.1.2
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9695656278/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -fsanitize=address -Daddress_sanitizer_enabled -fno-omit-frame-pointer -fsanitize-blacklist=/home/runner/actions_runner/_work/ydb/ydb/build/sanitize-blacklist.txt -fno-sanitize-link-runtime -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -DNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-deprecated-literal-operator -Wno-unused-but-set-variable -Wno-unused-private-field -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-11 15:22:03,097 - DEBUG - ya.test - _save_outputs: Command (pid 550452) errors:

2025-11-11 15:22:03,098 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 2 version:
Git info:
    Commit: edc42c4313d1ecf4073f2f2b8dc05dd5cba26c17
    Branch: 
    Author: ubyte <himeraster@gmail.com>
    Summary: Merge 0e8f5d4b993a763788a819dc96a27139b4faa153 into d428e61cc4e3c2ff244c18f2eff147ecafd8254a
2025-11-11 15:22:03,098 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-11-11 15:22:03,118 - INFO - ya.test - pytest_runtest_call: Test call (class_name: test_dispatch.py::TestMapping, test_name: test_mapping_with_nodes)
2025-11-11 15:22:03,143 - DEBUG - root - create_stream: Requesting CreateStream.
Database: "local".
Request:
stream_name: "/local/test_mapping_with_nodes_input"
shard_count: 1
write_quota_kb_per_sec: 1024
retention_period_hours: 1

2025-11-11 15:22:03,294 - DEBUG - root - _get_and_check_result: Response: operation {
  ready: true
  status: SUCCESS
}

2025-11-11 15:22:03,295 - DEBUG - root - _get_and_check_result: Result: 
2025-11-11 15:22:08,479 - DEBUG - root - create_query_impl: Request: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "df3b25d2-fc86-4e58-8740-c9b842921862"

2025-11-11 15:22:10,415 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-11 15:22:10,416 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-11 15:22:10,447 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-11 15:22:10,448 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 99bb5dc9-62b9-4920-a3f9-c86a29b2086c, localhost:8186): creating call state
2025-11-11 15:22:10,448 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 99bb5dc9-62b9-4920-a3f9-c86a29b2086c, localhost:8186): request = { database: "local" }
2025-11-11 15:22:10,459 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 99bb5dc9-62b9-4920-a3f9-c86a29b2086c, localhost:8186): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-ox5xijdfoi.auto.internal" port: 8186 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-11 15:22:10,460 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-ox5xijdfoi.auto.internal:8186, location 1, ssl: False>]>
2025-11-11 15:22:10,461 - INFO - ydb.connection - close: Closing channel for endpoint localhost:8186
2025-11-11 15:22:11,672 - DEBUG - root - create_query_impl: Result: query_id: "ptqudslj4v17l09hh0cd"

2025-11-11 15:22:12,979 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-11 15:22:12,980 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-11 15:22:12,994 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-11 15:22:12,995 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 44713d26-1e8a-448a-8162-918ce1fc2251, localhost:8186): creating call state
2025-11-11 15:22:12,996 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 44713d26-1e8a-448a-8162-918ce1fc2251, localhost:8186): request = { database: "local" }
2025-11-11 15:22:13,008 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 44713d26-1e8a-448a-8162-918ce1fc2251, localhost:8186): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-ox5xijdfoi.auto.internal" port: 8186 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-11 15:22:13,009 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-ox5xijdfoi.auto.internal:8186, location 1, ssl: False>]>
2025-11-11 15:22:13,010 - INFO - ydb.connection - close: Closing channel for endpoint localhost:8186
2025-11-11 15:22:24,827 - DEBUG - root - control_query: Result: 
2025-11-11 15:22:25,362 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj4v17l09hh0cd"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874528
        nanos: 587837000
      }
      modified_at {
        seconds: 1762874544
        nanos: 772872000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874533
      nanos: 724000000
    }
    execute_mode: RUN
    status: ABORTING_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj4v17j73alk8j-ptqudslj4v17l09hh0cd"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874528
      nanos: 587837000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"1.09s\",\"count\":3,\"avg\":\"0.36s\",\"max\":\"0.73s\",\"min\":\"0.10s\"},\"MaxMemoryUsage\":{\"sum\":393216,\"count\":3,\"avg\":131072,\"max\":131072,\"min\":131072},\"IngressQueuedBytes\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj538elegk5mfd\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:27,458 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj4v17l09hh0cd"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874528
        nanos: 587837000
      }
      modified_at {
        seconds: 1762874544
        nanos: 772872000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874533
      nanos: 724000000
    }
    finished_at {
      seconds: 1762874545
      nanos: 363000000
    }
    execute_mode: RUN
    status: ABORTED_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj4v17j73alk8j-ptqudslj4v17l09hh0cd"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874528
      nanos: 587837000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  issue {
    message: "ABORTED_BY_USER"
    severity: 1
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"1.09s\",\"count\":3,\"avg\":\"0.36s\",\"max\":\"0.73s\",\"min\":\"0.10s\"},\"MaxMemoryUsage\":{\"sum\":393216,\"count\":3,\"avg\":131072,\"max\":131072,\"min\":131072},\"IngressQueuedBytes\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj538elegk5mfd\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:27,805 - DEBUG - root - create_query_impl: Request: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "cc6571d9-0e64-4f6e-be46-7624f0b85902"

2025-11-11 15:22:28,033 - DEBUG - root - create_query_impl: Result: query_id: "ptqudslj4cjgnk4biieq"

2025-11-11 15:22:33,027 - DEBUG - root - control_query: Result: 
2025-11-11 15:22:33,103 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj4cjgnk4biieq"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874547
        nanos: 911687000
      }
      modified_at {
        seconds: 1762874552
        nanos: 977989000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874549
      nanos: 79000000
    }
    execute_mode: RUN
    status: ABORTING_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj4cjgn4tqu3tq-ptqudslj4cjgnk4biieq"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874547
      nanos: 911687000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj4ct5i0gceo0u\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:35,190 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj4cjgnk4biieq"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874547
        nanos: 911687000
      }
      modified_at {
        seconds: 1762874552
        nanos: 977989000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874549
      nanos: 79000000
    }
    finished_at {
      seconds: 1762874553
      nanos: 635000000
    }
    execute_mode: RUN
    status: ABORTED_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj4cjgn4tqu3tq-ptqudslj4cjgnk4biieq"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874547
      nanos: 911687000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  issue {
    message: "ABORTED_BY_USER"
    severity: 1
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj4ct5i0gceo0u\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:35,498 - DEBUG - root - create_query_impl: Request: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "4169738f-02e6-4d13-b969-06316c4969bc"

2025-11-11 15:22:35,678 - DEBUG - root - create_query_impl: Result: query_id: "ptqudslj459j5mk4qdim"

2025-11-11 15:22:40,671 - DEBUG - root - control_query: Result: 
2025-11-11 15:22:40,782 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj459j5mk4qdim"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874555
        nanos: 576897000
      }
      modified_at {
        seconds: 1762874560
        nanos: 582154000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874556
      nanos: 323000000
    }
    execute_mode: RUN
    status: ABORTING_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj459j544vt3i8-ptqudslj459j5mk4qdim"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874555
      nanos: 576897000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj45j2vppq5bpv\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:42,865 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj459j5mk4qdim"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874555
        nanos: 576897000
      }
      modified_at {
        seconds: 1762874560
        nanos: 582154000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874556
      nanos: 323000000
    }
    finished_at {
      seconds: 1762874560
      nanos: 804000000
    }
    execute_mode: RUN
    status: ABORTED_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj459j544vt3i8-ptqudslj459j5mk4qdim"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874555
      nanos: 576897000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  issue {
    message: "ABORTED_BY_USER"
    severity: 1
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj45j2vppq5bpv\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:43,107 - DEBUG - root - create_query_impl: Request: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "2f6278f2-207d-4998-b3db-c06425dbabe2"

2025-11-11 15:22:43,307 - DEBUG - root - create_query_impl: Result: query_id: "ptqudslj3u12uaa4g7kc"

2025-11-11 15:22:48,276 - DEBUG - root - control_query: Result: 
2025-11-11 15:22:48,377 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj3u12uaa4g7kc"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874563
        nanos: 195712000
      }
      modified_at {
        seconds: 1762874568
        nanos: 206276000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874564
      nanos: 58000000
    }
    execute_mode: RUN
    status: ABORTING_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj3u12tranu8tf-ptqudslj3u12uaa4g7kc"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874563
      nanos: 195712000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj3u95v3h0148j\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:50,444 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudslj3u12uaa4g7kc"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762874563
        nanos: 195712000
      }
      modified_at {
        seconds: 1762874568
        nanos: 206276000
      }
      revision: 2
    }
    started_at {
      seconds: 1762874564
      nanos: 58000000
    }
    finished_at {
      seconds: 1762874569
      nanos: 18000000
    }
    execute_mode: RUN
    status: ABORTED_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudslj3u12tranu8tf-ptqudslj3u12uaa4g7kc"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762874563
      nanos: 195712000
    }
  }
  content {
    type: STREAMING
    name: "a"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "SELECT Data FROM yds.`test_mapping_with_nodes_input` LIMIT 1"
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"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\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
  }
  issue {
    message: "ABORTED_BY_USER"
    severity: 1
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}"
  }
  result_set_meta {
    column {
      name: "Data"
      type {
        type_id: STRING
      }
    }
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"yds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"yds\" \'\"local\" \'\"test_mapping_with_nodes_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"Data\"))\n(let $7 \'(\'\"SharedReading\" \'\"0\"))\n(let $8 \'(\'(\'\"Endpoint\" \'\"localhost:8186\") $7 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslj3u95v3h0148j\") \'(\'\"AddBearerToToken\" \'1)))\n(let $9 (DqPqTopicSource world $5 $6 $8 (SecureParam \'\"cluster:default_yds\") \'\"\" $4 \'\"\"))\n(let $10 (Uint64 \'1))\n(let $11 (DqStage \'((DqSource $3 $9)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($7))))\n  (let $18 (DqSourceWideWrap $16 $3 $4 $17))\n  (return (Take (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))) $10))\n))) \'(\'(\'\"_logical_id\" \'200274))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($20) (Take $20 $10)) \'(\'(\'\"_logical_id\" \'200287))))\n(let $13 (DqStage \'((DqCnUnionAll (TDqOutput $12 \'\"0\"))) (lambda \'($21) $21) \'(\'(\'\"_logical_id\" \'200324))))\n(let $14 \'(\'(\'type) \'(\'autoref) \'(\'columns $6)))\n(let $15 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $13 \'\"0\") \'()) $14 \'\"dq\"))\n(return (Commit! (Commit! $15 $2) (DataSink \'\"pq\" \'\"yds\")))\n)\n"
  }
}

2025-11-11 15:22:50,451 - INFO - ya.test - pytest_runtest_teardown: Test teardown
2025-11-11 15:23:13,524 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-11 15:23:13,525 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-11 15:23:13,562 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-11 15:23:13,563 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, b0b4d853-cbf2-4d82-9029-241006a5ab09, localhost:8186): creating call state
2025-11-11 15:23:13,564 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, b0b4d853-cbf2-4d82-9029-241006a5ab09, localhost:8186): request = { database: "local" }
2025-11-11 15:23:13,569 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, b0b4d853-cbf2-4d82-9029-241006a5ab09, localhost:8186): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-ox5xijdfoi.auto.internal" port: 8186 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-11 15:23:13,570 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-ox5xijdfoi.auto.internal:8186, location 1, ssl: False>]>
2025-11-11 15:23:13,571 - INFO - ydb.connection - close: Closing channel for endpoint localhost:8186
2025-11-11 15:23:27,469 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:23226/1
2025-11-11 15:23:27,471 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/21772
2025-11-11 15:23:27,472 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/24931
2025-11-11 15:23:27,472 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/1233
2025-11-11 15:23:27,473 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/23226
2025-11-11 15:23:27,473 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/64480
2025-11-11 15:23:27,474 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/2596
2025-11-11 15:23:30,828 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-11 15:23:30,829 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-11 15:23:30,880 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-11 15:23:30,881 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, a63dc139-8644-44c2-8513-f30a31a6cadd, localhost:8186): creating call state
2025-11-11 15:23:30,882 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, a63dc139-8644-44c2-8513-f30a31a6cadd, localhost:8186): request = { database: "local" }
2025-11-11 15:23:30,890 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, a63dc139-8644-44c2-8513-f30a31a6cadd, localhost:8186): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-ox5xijdfoi.auto.internal" port: 8186 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-11 15:23:30,891 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-ox5xijdfoi.auto.internal:8186, location 1, ssl: False>]>
2025-11-11 15:23:30,892 - INFO - ydb.connection - close: Closing channel for endpoint localhost:8186
2025-11-11 15:23:34,476 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:4236/1
2025-11-11 15:23:34,480 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/9320
2025-11-11 15:23:34,481 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/26046
2025-11-11 15:23:34,481 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/1825
2025-11-11 15:23:34,482 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/4236
2025-11-11 15:23:34,482 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/3727
2025-11-11 15:23:34,482 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/2342
2025-11-11 15:23:37,493 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:20562/2
2025-11-11 15:23:41,496 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:15118/1
2025-11-11 15:23:41,499 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/12304
2025-11-11 15:23:41,500 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/8250
2025-11-11 15:23:41,500 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/13696
2025-11-11 15:23:41,501 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/20562
2025-11-11 15:23:41,501 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/13817
2025-11-11 15:23:41,501 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/17927
2025-11-11 15:23:41,502 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/8836
2025-11-11 15:23:41,502 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/15118
2025-11-11 15:23:41,502 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/64932
2025-11-11 15:23:41,503 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/1654
