Skip to content

Commit 1fff321

Browse files
yumkamGazizonoki
authored andcommitted
pq write: pass query/task info into sdk logs (#14477)
Co-authored-by: Bulat <bylatgr@gmail.com>
1 parent e769c9c commit 1fff321

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
@@ -297,6 +297,7 @@ class TDqPqWriteActor : public NActors::TActor<TDqPqWriteActor>, public IDqCompu
297297

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

ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -988,6 +988,7 @@ TStringBuilder TWriteSessionImpl::LogPrefixImpl() const {
988988
Y_ABORT_UNLESS(Lock.IsLocked());
989989

990990
TStringBuilder ret;
991+
ret << " TraceId [" << Settings.TraceId_ << "] ";;
991992
ret << " SessionId [" << SessionId << "] ";
992993

993994
if (Settings.PartitionId_.has_value() || DirectWriteToPartitionId.has_value()) {

0 commit comments

Comments
 (0)