diff options
| author | pg <pg@yandex-team.com> | 2023-09-07 02:09:29 +0300 |
|---|---|---|
| committer | pg <pg@yandex-team.com> | 2023-09-07 02:29:02 +0300 |
| commit | 1b3890fac5c582fc1e4696a7b248230d13b15e08 (patch) | |
| tree | 18e3c998293cda8f613340e389206e8e9ea11590 | |
| parent | ed4f5dcd2a3d3ade430882d08513356cc33e9ada (diff) | |
| download | ydb-1b3890fac5c582fc1e4696a7b248230d13b15e08.tar.gz | |
| -rw-r--r-- | ydb/library/yql/providers/s3/provider/yql_s3_datasink_execution.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/s3/provider/yql_s3_datasink_execution.cpp b/ydb/library/yql/providers/s3/provider/yql_s3_datasink_execution.cpp index 99e491670a..edc75c1598 100644 --- a/ydb/library/yql/providers/s3/provider/yql_s3_datasink_execution.cpp +++ b/ydb/library/yql/providers/s3/provider/yql_s3_datasink_execution.cpp @@ -95,10 +95,10 @@ private: YQL_ENSURE(dqWriteStatus != TStatus::Async, "ApplyAsyncChanges should not return Async."); - if (TStatus::Repeat == dqWriteStatus) + if (dqWriteStatus == TStatus::Repeat) output->SetState(TExprNode::EState::ExecutionRequired); - if (TStatus::Ok != dqWriteStatus) + if (dqWriteStatus != TStatus::Ok) return dqWriteStatus; output->SetState(TExprNode::EState::ExecutionComplete); |