diff options
| author | yumkam <yumkam7@ydb.tech> | 2025-02-24 20:11:25 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-02-24 20:11:25 +0300 |
| commit | 4b706240f28681a5580e79e1b333a695a628f719 (patch) | |
| tree | 62018379ea2f6eae04791de59b79c80008d9f096 | |
| parent | 68cd15551f08a13b4b0f83b6b5c439cd357420dc (diff) | |
| download | ydb-4b706240f28681a5580e79e1b333a695a628f719.tar.gz | |
CA: fix inverted condition in TInputChannelInfo::IsPaused (#14094)
| -rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h | 2 |
1 files changed, 1 insertions, 1 deletions
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 index 28e44c1e98..151f8092a1 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h @@ -855,7 +855,7 @@ protected: } bool IsPaused() const { - return PendingWatermarks.empty() || PendingCheckpoint.has_value(); + return !PendingWatermarks.empty() || PendingCheckpoint.has_value(); } void Pause(TInstant watermark) { |