Incr/decr worker counter in Task Runner Actor (Compute Actor compatibility)

ref:f6e75580ba4c9104066099f55ea41205168049cd

2 files changed, 9 insertions, 9 deletions

diff --git a/ydb/library/yql/providers/dq/actors/worker_actor.cpp b/ydb/library/yql/providers/dq/actors/worker_actor.cpp
index a771742a79c..aaf3151d74f 100644
--- a/ydb/library/yql/providers/dq/actors/worker_actor.cpp
+++ b/ydb/library/yql/providers/dq/actors/worker_actor.cpp
@@ -89,20 +89,12 @@ public:
     {
         YQL_LOG_CTX_SCOPE(TraceId);
         YQL_LOG(DEBUG) << "TDqWorker created ";
-
-        if (RuntimeData) {
-            RuntimeData->OnWorkerStart(TraceId);
-        }
     }
 
     ~TDqWorker()
     {
         YQL_LOG_CTX_SCOPE(TraceId);
         YQL_LOG(DEBUG) << "TDqWorker destroyed ";
-
-        if (RuntimeData) {
-            RuntimeData->OnWorkerStop(TraceId);
-        }
     }
 
     void DoPassAway() override {
diff --git a/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp b/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
index 43a12111f4e..bee45dd6384 100644
--- a/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
+++ b/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
@@ -58,9 +58,17 @@ public:
         , RuntimeData(runtimeData)
         , ClusterName(RuntimeData ? RuntimeData->ClusterName : "local")
     {
+        if (RuntimeData) {
+            RuntimeData->OnWorkerStart(TraceId);
+        }
     }
 
-    ~TTaskRunnerActor() { }
+    ~TTaskRunnerActor()
+    {
+        if (RuntimeData) {
+            RuntimeData->OnWorkerStop(TraceId);
+        }
+    }
 
     STRICT_STFUNC(Handler, {
         cFunc(NActors::TEvents::TEvPoison::EventType, TTaskRunnerActor::PassAway);