CA: LastRunStatus was always overwritten (backport #14710) (#14814)

yumkam · web-flow · commit 9e8341f78a19 · 2025-02-20T10:53:40.000+03:00
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
@@ -388,13 +388,13 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
     }
 
     void ProcessOutputsImpl(ERunStatus status) {
-        ProcessOutputsState.LastRunStatus = status;
-
         CA_LOG_T("ProcessOutputsState.Inflight: " << ProcessOutputsState.Inflight);
         if (ProcessOutputsState.Inflight == 0) {
             ProcessOutputsState = TProcessOutputsState();
         }
 
+        ProcessOutputsState.LastRunStatus = status;
+
         for (auto& entry : OutputChannelsMap) {
             const ui64 channelId = entry.first;
             TOutputChannelInfo& outputChannel = entry.second;

Original file line number	Diff line number	Diff line change
`@@ -388,13 +388,13 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>`
`388`	`388`	`}`
`389`	`389`
`390`	`390`	`void ProcessOutputsImpl(ERunStatus status) {`
`391`		`- ProcessOutputsState.LastRunStatus = status;`
`392`		`-`
`393`	`391`	`CA_LOG_T("ProcessOutputsState.Inflight: " << ProcessOutputsState.Inflight);`
`394`	`392`	`if (ProcessOutputsState.Inflight == 0) {`
`395`	`393`	`ProcessOutputsState = TProcessOutputsState();`
`396`	`394`	`}`
`397`	`395`
	`396`	`+ ProcessOutputsState.LastRunStatus = status;`
	`397`	`+`
`398`	`398`	`for (auto& entry : OutputChannelsMap) {`
`399`	`399`	`const ui64 channelId = entry.first;`
`400`	`400`	`TOutputChannelInfo& outputChannel = entry.second;`