2025-12-12T11:57:49.144304Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:49.144549Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:49.144807Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:49.144819Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:49.144823Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:49.144865Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Two_WriteSession/topic_A" message_group_id: "test-message_group_id" }
2025-12-12T11:57:49.144998Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:49.145044Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:49.145051Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Two_WriteSession/topic_B" message_group_id: "test-message_group_id" }
2025-12-12T11:57:49.145105Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:49.150935Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:49.150959Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540669150 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:49.150988Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0"
2025-12-12T11:57:49.150993Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:49.151008Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:49.151032Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540669151 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:49.151055Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0"
2025-12-12T11:57:49.151060Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:49.151075Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:49.151105Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:49.151125Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:49.151271Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:49.152452Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:49.152456Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:57:49.152468Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:49.152471Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:49.152474Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:49.152476Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:49.152717Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:49.152751Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:49.152833Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:49.152842Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:49.152859Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Two_WriteSession/topic_A" partition_with_generation { generation: 1 } }
2025-12-12T11:57:49.152859Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/TxUsageQuery-DirectRead_WriteToTopic_Two_WriteSession/topic_B" partition_with_generation { generation: 1 } }
2025-12-12T11:57:49.152932Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:49.152937Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:49.153900Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:49.153919Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|8fbdb46c-31c4e377-67b9e4ce-579d6a51_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0"
2025-12-12T11:57:49.153923Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:49.153947Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:49.153959Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|3cadd8ef-482317f8-67cbda6e-b61b18c5_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0"
2025-12-12T11:57:49.153965Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:49.154017Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=M2ViYjNjYjEtZjk2M2MxMmMtMTY5N2NkYjItYjJiMzAwNjc=, 01kc96s9pq7s4cw28b0rjv30cg}, WriteCount=1, AckCount=0
2025-12-12T11:57:49.154039Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:49.154076Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId={ydb://session/3?node_id=1&id=M2ViYjNjYjEtZjk2M2MxMmMtMTY5N2NkYjItYjJiMzAwNjc=, 01kc96s9pq7s4cw28b0rjv30cg}, WriteCount=1, AckCount=0
2025-12-12T11:57:49.154081Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:49.154197Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:49.154207Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:49.154246Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:49.154260Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:49.157127Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:49.157161Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:49.157170Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=M2ViYjNjYjEtZjk2M2MxMmMtMTY5N2NkYjItYjJiMzAwNjc=, 01kc96s9pq7s4cw28b0rjv30cg}, WriteCount=1, AckCount=1
2025-12-12T11:57:49.157173Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:49.168285Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:49.168354Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T11:57:49.168379Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId={ydb://session/3?node_id=1&id=M2ViYjNjYjEtZjk2M2MxMmMtMTY5N2NkYjItYjJiMzAwNjc=, 01kc96s9pq7s4cw28b0rjv30cg}, WriteCount=1, AckCount=1
2025-12-12T11:57:49.168383Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:49.174346Z :INFO: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:49.174368Z :INFO: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:49.174377Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:49.174636Z :INFO: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:49.174645Z :DEBUG: [local]  TraceId []  SessionId [9449fce2-6e8445b5-df336331-7eed48a9|671373c2-5173ad2a-ce3d21f1-c30c76f6_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T11:57:49.174673Z :INFO: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T11:57:49.174676Z :INFO: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:49.174679Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:49.174701Z :INFO: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:49.174705Z :DEBUG: [local]  TraceId []  SessionId [25ad61a3-6add3cbf-1243594d-ef66f90d|7eea5a1b-e62ac66f-a12a13c7-be3cd482_0]  PartitionId [0]  Generation [1] Write session: destroy
