YQL-17755 fix drying input up

zverevgeny · zverevgeny · commit 5c0b89092391 · 2024-02-05T19:24:59.000Z
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_input_helper.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_input_helper.h
@@ -83,8 +83,9 @@ struct TComputeActorAsyncInputHelper {
                     Pause(*watermark);
                 }
             }
+            const bool emptyBatch = batch.empty();
             AsyncInputPush(std::move(batch), space, finished);
-            if (!batch.empty()) {
+            if (!emptyBatch) {
                 // If we have read some data, we must run such reading again
                 // to process the case when async input notified us about new data
                 // but we haven't read all of it.

Original file line number	Diff line number	Diff line change
`@@ -83,8 +83,9 @@ struct TComputeActorAsyncInputHelper {`
`83`	`83`	`Pause(*watermark);`
`84`	`84`	`}`
`85`	`85`	`}`
	`86`	`+ const bool emptyBatch = batch.empty();`
`86`	`87`	`AsyncInputPush(std::move(batch), space, finished);`
`87`		`- if (!batch.empty()) {`
	`88`	`+ if (!emptyBatch) {`
`88`	`89`	`// If we have read some data, we must run such reading again`
`89`	`90`	`// to process the case when async input notified us about new data`
`90`	`91`	`// but we haven't read all of it.`