Skip to content

Commit 95333f6

Browse files
authored
pq write: pass query/task info into sdk logs (backport #14477, #14884) (#14535)
1 parent 9e8341f commit 95333f6

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -296,6 +296,7 @@ class TDqPqWriteActor : public NActors::TActor<TDqPqWriteActor>, public IDqCompu
296296

297297
NYdb::NTopic::TWriteSessionSettings GetWriteSessionSettings() {
298298
return NYdb::NTopic::TWriteSessionSettings(SinkParams.GetTopicPath(), GetSourceId(), GetSourceId())
299+
.TraceId(LogPrefix)
299300
.MaxMemoryUsage(FreeSpace)
300301
.Codec(SinkParams.GetClusterType() == NPq::NProto::DataStreams
301302
? NYdb::NTopic::ECodec::RAW

ydb/public/sdk/cpp/client/ydb_topic/impl/write_session_impl.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -965,6 +965,7 @@ void TWriteSessionImpl::OnReadDone(NYdbGrpc::TGrpcStatus&& grpcStatus, size_t co
965965

966966
TStringBuilder TWriteSessionImpl::LogPrefix() const {
967967
TStringBuilder ret;
968+
ret << " TraceId [" << Settings.TraceId_ << "] ";
968969
ret << " SessionId [" << SessionId << "] ";
969970

970971
if (Settings.PartitionId_.Defined() || DirectWriteToPartitionId.Defined()) {

0 commit comments

Comments
 (0)