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 f4f3a94c5c9b..aca3d711d06a 100644
--- a/ydb/library/yql/providers/dq/actors/task_controller_impl.h
+++ b/ydb/library/yql/providers/dq/actors/task_controller_impl.h
@@ -442,8 +442,7 @@ class TTaskControllerImpl: public NActors::TActor<TDerived> {
 
         for (const auto& stats : s.GetSources()) {
             auto labels = commonLabels;
-            labels["Source"] = ToString(stats.GetInputIndex());
-            labels["Name"] = stats.GetIngressName();
+            labels["Source"] = stats.GetIngressName();
             TaskStat.AddAsyncStats(stats.GetIngress(), labels, "Ingress");
             TaskStat.AddAsyncStats(stats.GetPush(),  labels, "Push");
             TaskStat.AddAsyncStats(stats.GetPop(), labels, "Pop");