Skip to content

Commit 146b12d

Browse files
authored
ContinueExecute on non-empty transform (backport #12201) (#12450)
1 parent 995b753 commit 146b12d

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -439,6 +439,14 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
439439
return;
440440
}
441441

442+
if (status != ERunStatus::Finished) {
443+
for (auto& [id, inputTransform] : InputTransformsMap) {
444+
if (!inputTransform.Buffer->Empty()) {
445+
ContinueExecute(EResumeSource::CAPendingInput);
446+
}
447+
}
448+
}
449+
442450
if (status != ERunStatus::Finished) {
443451
// If the incoming channel's buffer was full at the moment when last ChannelDataAck event had been sent,
444452
// there will be no attempts to send a new piece of data from the other side of this channel.

0 commit comments

Comments
 (0)