Better trace for sinks (#16460)

nikvas0 · web-flow · commit 1408171ea0ff · 2025-03-31T15:25:58.000+03:00
diff --git a/ydb/core/kqp/runtime/kqp_write_actor.cpp b/ydb/core/kqp/runtime/kqp_write_actor.cpp
@@ -2921,7 +2921,7 @@ class TKqpForwardWriteActor : public TActorBootstrapped<TKqpForwardWriteActor>,
             Settings.GetTable().GetOwnerId(),
             Settings.GetTable().GetTableId(),
             Settings.GetTable().GetVersion())
-        , ForwardWriteActorSpan(TWilsonKqp::ForwardWriteActor, NWilson::TTraceId(args.TraceId), "TKqpForwardWriteActor")
+        , ForwardWriteActorSpan(TWilsonKqp::ForwardWriteActor, NWilson::TTraceId(args.TraceId), "ForwardWriteActor")
     {
         EgressStats.Level = args.StatsLevel;
 
diff --git a/ydb/core/tx/datashard/datashard_ut_trace.cpp b/ydb/core/tx/datashard/datashard_ut_trace.cpp
@@ -313,7 +313,7 @@ Y_UNIT_TEST_SUITE(TDataShardTrace) {
                 ExpectedSpan("DataExecuter",
                     "WaitForTableResolve",
                     ExpectedSpan("ComputeActor",
-                        Repeat(("TKqpForwardWriteActor"), 1)),
+                        Repeat(("ForwardWriteActor"), 1)),
                     "RunTasks",
                     ExpectedSpan(
                         "Commit",

Original file line number	Diff line number	Diff line change
`@@ -2921,7 +2921,7 @@ class TKqpForwardWriteActor : public TActorBootstrapped<TKqpForwardWriteActor>,`
`2921`	`2921`	`Settings.GetTable().GetOwnerId(),`
`2922`	`2922`	`Settings.GetTable().GetTableId(),`
`2923`	`2923`	`Settings.GetTable().GetVersion())`
`2924`		`- , ForwardWriteActorSpan(TWilsonKqp::ForwardWriteActor, NWilson::TTraceId(args.TraceId), "TKqpForwardWriteActor")`
	`2924`	`+ , ForwardWriteActorSpan(TWilsonKqp::ForwardWriteActor, NWilson::TTraceId(args.TraceId), "ForwardWriteActor")`
`2925`	`2925`	`{`
`2926`	`2926`	`EgressStats.Level = args.StatsLevel;`
`2927`	`2927`