reduce Inflight and reset PopStarted when skipping send

yumkam · yumkam · commit 39f926e6bcdc · 2025-03-05T14:27:06.000+03:00
diff --git a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp
@@ -852,6 +852,8 @@ class TDqAsyncComputeActor : public TDqComputeActorBase<TDqAsyncComputeActor, TC
         if (!Channels->ShouldSkipData(outputChannel.ChannelId) && !Channels->CanSendChannelData(outputChannel.ChannelId)) {
             // Once RetryState will be reset, channel will trigger either ResumeExecution or PeerFinished; either way execution will re-reach this function
             CA_LOG_D("OnOutputChannelData return because Channel can't send channel data, channel: " << outputChannel.ChannelId);
+            outputChannel.PopStarted = false;
+            ProcessOutputsState.Inflight--;
             return;
         }
         if (outputChannel.AsyncData) {

Original file line number	Diff line number	Diff line change
`@@ -852,6 +852,8 @@ class TDqAsyncComputeActor : public TDqComputeActorBase<TDqAsyncComputeActor, TC`
`852`	`852`	`if (!Channels->ShouldSkipData(outputChannel.ChannelId) && !Channels->CanSendChannelData(outputChannel.ChannelId)) {`
`853`	`853`	`// Once RetryState will be reset, channel will trigger either ResumeExecution or PeerFinished; either way execution will re-reach this function`
`854`	`854`	`CA_LOG_D("OnOutputChannelData return because Channel can't send channel data, channel: " << outputChannel.ChannelId);`
	`855`	`+ outputChannel.PopStarted = false;`
	`856`	`+ ProcessOutputsState.Inflight--;`
`855`	`857`	`return;`
`856`	`858`	`}`
`857`	`859`	`if (outputChannel.AsyncData) {`