Add correct actorids to logs

1 files changed, 3 insertions, 2 deletions

diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp
index fe0224adb3..f1b77ca372 100644
--- a/ydb/core/kqp/runtime/kqp_read_actor.cpp
+++ b/ydb/core/kqp/runtime/kqp_read_actor.cpp
@@ -261,7 +261,7 @@ public:
         NKikimrTxDataShard::TKqpReadRangesSourceSettings&& settings,
         const NYql::NDq::TDqAsyncIoFactory::TSourceArguments& args)
         : Settings(std::move(settings))
-        , LogPrefix(TStringBuilder() << "SelfId: " << this->SelfId() << ", TxId: " << args.TxId << ", task: " << args.TaskId << ". ")
+        , LogPrefix(TStringBuilder() << "TxId: " << args.TxId << ", task: " << args.TaskId << ", CA Id" << args.ComputeActorId << ". ")
         , ComputeActorId(args.ComputeActorId)
         , InputIndex(args.InputIndex)
         , TypeEnv(args.TypeEnv)
@@ -311,6 +311,7 @@ public:
     }
 
     void Bootstrap() {
+        LogPrefix = TStringBuilder() << "SelfId: " << this->SelfId() << ", " << LogPrefix;
         THolder<TShardState> stateHolder = MakeHolder<TShardState>(Settings.GetShardIdHint());
         PendingShards.PushBack(stateHolder.Get());
         auto& state = *stateHolder.Release();
@@ -982,7 +983,7 @@ private:
     TVector<NKikimrTxDataShard::TLock> BrokenLocks;
 
     ui32 MaxInFlight = 1024;
-    const TString LogPrefix;
+    TString LogPrefix;
     TTableId TableId;
 
     const TActorId ComputeActorId;