YQL-17755 fix drying input up (#1604)

zverevgeny · web-flow · commit a7a2a17e1d45 · 2024-02-06T06:42:57.000+03:00
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.`