Added log function to dqTaskRunner (#5772)

2 files changed, 4 insertions, 7 deletions

diff --git a/ydb/library/yql/dq/runtime/dq_output_channel.cpp b/ydb/library/yql/dq/runtime/dq_output_channel.cpp
index c7333c960d..6205a170a8 100644
--- a/ydb/library/yql/dq/runtime/dq_output_channel.cpp
+++ b/ydb/library/yql/dq/runtime/dq_output_channel.cpp
@@ -89,10 +89,6 @@ public:
     }
 
     void DoPush(NUdf::TUnboxedValue* values, ui32 width) {
-        ui64 rowsInMemory = PackedRowCount + ChunkRowCount;
-
-        LOG("Push request, rows in memory: " << rowsInMemory << ", bytesInMemory: " << (PackedDataSize + Packer.PackedSizeEstimate())
-            << ", finished: " << Finished);
         YQL_ENSURE(!IsFull());
 
         if (Finished) {
@@ -178,8 +174,6 @@ public:
 
     [[nodiscard]]
     bool Pop(TDqSerializedBatch& data) override {
-        LOG("Pop request, rows in memory: " << GetValuesCount() << ", finished: " << Finished);
-
         if (!HasData()) {
             PushStats.TryPause();
             if (Finished) {
diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp b/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
index 94271986ff..a97fc95fcb 100644
--- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
+++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
@@ -262,7 +262,10 @@ public:
         }
         auto ctx = ExecutionContext;
         ctx.FuncProvider = TaskTransformFactory(settings.TaskParams, ctx.FuncRegistry);
-        return MakeDqTaskRunner(alloc, ctx, settings, { });
+        return MakeDqTaskRunner(alloc, ctx, settings, [taskId = task.GetId(), traceId = traceId](const TString& message) {
+            YQL_LOG_CTX_ROOT_SESSION_SCOPE(traceId, ToString(taskId));
+            YQL_CLOG(DEBUG, ProviderDq) << message;
+        });
     }
 
 private: