==== TMockDiscovery server started on port 41957
==== TMockDiscovery set good endpoint nodes 
==== TMockDiscovery add endpoints, firstNodeId 1, nodeCount 1, port 32613
==== ListEndpoints request: database: "local"
==== ListEndpoints response: operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "localhost" port: 32613 node_id: 1 } } } }
2025-12-12T11:57:23.594087Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: try to update token
2025-12-12T11:57:23.594236Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Start write session. Will connect to nodeId: 0
2025-12-12T11:57:23.596423Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: write to message_group: test-message_group_id
2025-12-12T11:57:23.596460Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: send init request: init_request { path: "sdk_tests/LocalPartition-DirectRead_WithoutPartition/test-topic" producer_id: "test-message_group_id" message_group_id: "test-message_group_id" }
2025-12-12T11:57:23.596465Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-12T11:57:23.596575Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:23.602118Z :DEBUG: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:23.602135Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765540643602 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:57:23.602154Z :INFO: [local]  TraceId []  SessionId []  MessageGroupId [test-message_group_id] Write session established. Init response: session_id: "test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0"
2025-12-12T11:57:23.602159Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0
2025-12-12T11:57:23.602168Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  MessageGroupId [test-message_group_id] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:23.602188Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T11:57:23.602195Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/sdk_tests/LocalPartition-DirectRead_WithoutPartition/test-topic partition_id=0
2025-12-12T11:57:23.602227Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:57:23.603286Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_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:23.603297Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-12-12T11:57:23.603305Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:57:23.603312Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-12T11:57:23.603356Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:57:23.603542Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:23.603641Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:57:23.603669Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/LocalPartition-DirectRead_WithoutPartition/test-topic" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-12-12T11:57:23.603674Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-12-12T11:57:23.603778Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:57:23.608304Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:23.608330Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0"
2025-12-12T11:57:23.608335Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0
2025-12-12T11:57:23.608343Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T11:57:23.608399Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T11:57:23.608432Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:57:23.608699Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T11:57:23.608710Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T11:57:23.610342Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:57:23.610386Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } 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:23.610395Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T11:57:23.610399Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T11:57:23.708538Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:57:23.708583Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:57:23.708950Z :INFO: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:57:23.708963Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T11:57:23.708982Z :TRACE: [local] TRACE_EVENT Error  status=CLIENT_CANCELLED
2025-12-12T11:57:23.708992Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
==== Events count: 8
==== Event: InitRequest
==== Event: InitResponse
==== partition_id=0
==== session_id=test-message_group_id|eb4b5800-dfe6ccaf-84ffeb27-1308c900_0
==== Event: DescribePartitionRequest
==== path=local/sdk_tests/LocalPartition-DirectRead_WithoutPartition/test-topic
==== partition_id=0
==== Event: DescribePartitionResponse
==== partition_id=0
==== active=1
==== pl_node_id=1
==== pl_generation=1
==== Event: PreferredPartitionLocation
==== Endpoint=
==== Generation=1
==== NodeId=1
==== Event: InitRequest
==== pwg_partition_id=0
==== pwg_generation=1
==== Event: InitResponse
==== partition_id=0
==== session_id=test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0
==== Event: Error
==== status=CLIENT_CANCELLED
2025-12-12T11:57:23.712342Z :DEBUG: [local]  TraceId []  SessionId [test-message_group_id|f7f57490-bcc6cccc-c542bf95-237c77d4_0]  PartitionId [0]  Generation [1] Write session: destroy
