aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@ydb.tech>2023-06-26 16:48:42 +0300
committeraozeritsky <aozeritsky@ydb.tech>2023-06-26 16:48:42 +0300
commitc08fa38d23bc42decb87e0aca4b78916897b758c (patch)
treed95f455f7dd26a6eaf9f079ef86f996e5dded4e1
parente1ed54a7794c7978f30460317be22e5bc9561b31 (diff)
downloadydb-c08fa38d23bc42decb87e0aca4b78916897b758c.tar.gz
Use publicId as stageId for statistics when possible
-rw-r--r--ydb/library/yql/providers/dq/actors/task_controller_impl.h2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/dq/actors/task_controller_impl.h b/ydb/library/yql/providers/dq/actors/task_controller_impl.h
index 796877d193..a982039833 100644
--- a/ydb/library/yql/providers/dq/actors/task_controller_impl.h
+++ b/ydb/library/yql/providers/dq/actors/task_controller_impl.h
@@ -337,7 +337,7 @@ private:
YQL_ENSURE(x.GetTasks().size() == 1);
auto& s = x.GetTasks(0);
ui64 taskId = s.GetTaskId();
- ui64 stageId = s.GetStageId();
+ ui64 stageId = Stages.Value(taskId, s.GetStageId());
#define ADD_COUNTER(name) \
if (stats.Get ## name()) { \