Fixed QueuedTimeUs value

GrigoriyPA · GrigoriyPA · commit 42d826744eec · 2024-07-23T06:43:49.000Z
diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp
@@ -1554,7 +1554,7 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
         stats->DurationUs = ((TInstant::Now() - QueryState->StartTime).MicroSeconds());
         stats->WorkerCpuTimeUs = (QueryState->GetCpuTime().MicroSeconds());
         if (const auto continueTime = QueryState->ContinueTime) {
-            stats->QueuedTimeUs = ((TInstant::Now() - continueTime).MicroSeconds());
+            stats->QueuedTimeUs = (continueTime - QueryState->StartTime).MicroSeconds();
         }
         if (QueryState->CompileResult) {
             stats->Compilation.emplace();

Original file line number	Diff line number	Diff line change
`@@ -1554,7 +1554,7 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {`
`1554`	`1554`	`stats->DurationUs = ((TInstant::Now() - QueryState->StartTime).MicroSeconds());`
`1555`	`1555`	`stats->WorkerCpuTimeUs = (QueryState->GetCpuTime().MicroSeconds());`
`1556`	`1556`	`if (const auto continueTime = QueryState->ContinueTime) {`
`1557`		`- stats->QueuedTimeUs = ((TInstant::Now() - continueTime).MicroSeconds());`
	`1557`	`+ stats->QueuedTimeUs = (continueTime - QueryState->StartTime).MicroSeconds();`
`1558`	`1558`	`}`
`1559`	`1559`	`if (QueryState->CompileResult) {`
`1560`	`1560`	`stats->Compilation.emplace();`