diff options
| author | Sergey Uzhakov <uzhastik@gmail.com> | 2022-05-04 18:56:53 +0300 |
|---|---|---|
| committer | Sergey Uzhakov <uzhastik@gmail.com> | 2022-05-04 18:56:53 +0300 |
| commit | d5c58fcc1b24193acf8aa43b7fddd70e94c3085d (patch) | |
| tree | 771cfa7c591d620ffc68e87d1b4bf72c49bbe477 | |
| parent | ed06eb39d49bb70d19999df60bdcae74c3f3b99b (diff) | |
| download | ydb-d5c58fcc1b24193acf8aa43b7fddd70e94c3085d.tar.gz | |
dq: use logging component KQP_COMPUTE instead of KQP_TASKS_RUNNER
ref:58766f8cf2da3d45f369115981c98e046449c9c4
| -rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp | 4 | ||||
| -rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_compute_actor.cpp | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp index bd44982504d..2d1d3e6d16f 100644 --- a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp +++ b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp @@ -14,7 +14,7 @@ namespace { bool IsDebugLogEnabled(const TActorSystem* actorSystem) { auto* settings = actorSystem->LoggerSettings(); - return settings && settings->Satisfies(NActors::NLog::EPriority::PRI_DEBUG, NKikimrServices::KQP_TASKS_RUNNER); + return settings && settings->Satisfies(NActors::NLog::EPriority::PRI_DEBUG, NKikimrServices::KQP_COMPUTE); } } // anonymous namespace @@ -44,7 +44,7 @@ public: TLogFunc logger; if (IsDebugLogEnabled(actorSystem)) { logger = [actorSystem, txId = this->GetTxId(), taskId = GetTask().GetId()] (const TString& message) { - LOG_DEBUG_S(*actorSystem, NKikimrServices::KQP_TASKS_RUNNER, "TxId: " << txId + LOG_DEBUG_S(*actorSystem, NKikimrServices::KQP_COMPUTE, "TxId: " << txId << ", task: " << taskId << ": " << message); }; } diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor.cpp b/ydb/library/yql/dq/actors/compute/dq_compute_actor.cpp index e8303b8a1bc..17bfa4491d1 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor.cpp +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor.cpp @@ -13,7 +13,7 @@ TDqExecutionSettings ExecutionSettings; bool IsDebugLogEnabled(const TActorSystem* actorSystem) { auto* settings = actorSystem->LoggerSettings(); - return settings && settings->Satisfies(NActors::NLog::EPriority::PRI_DEBUG, NKikimrServices::KQP_TASKS_RUNNER); + return settings && settings->Satisfies(NActors::NLog::EPriority::PRI_DEBUG, NKikimrServices::KQP_COMPUTE); } } // anonymous namespace @@ -46,7 +46,7 @@ public: TLogFunc logger; if (IsDebugLogEnabled(actorSystem)) { logger = [actorSystem, txId = this->GetTxId(), taskId = GetTask().GetId()] (const TString& message) { - LOG_DEBUG_S(*actorSystem, NKikimrServices::KQP_TASKS_RUNNER, "TxId: " << txId + LOG_DEBUG_S(*actorSystem, NKikimrServices::KQP_COMPUTE, "TxId: " << txId << ", task: " << taskId << ": " << message); }; } |