diff options
| author | Sergey Uzhakov <uzhastik@gmail.com> | 2022-06-22 20:52:17 +0300 |
|---|---|---|
| committer | Sergey Uzhakov <uzhastik@gmail.com> | 2022-06-22 20:52:17 +0300 |
| commit | f55ada30d924b55d15fad9001944df1323a9598a (patch) | |
| tree | e45bf413e7e50893f28495c118860aebc21149c6 | |
| parent | df26fd56ba474372827d3482c46a5f4b179014fc (diff) | |
| download | ydb-f55ada30d924b55d15fad9001944df1323a9598a.tar.gz | |
YQ-1178: enable coro reading by default
ref:d111242b19fb1dc6b94ef0678b55f77ff1bbaa6e
| -rw-r--r-- | ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp b/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp index 4ae8de33b4..22c9825004 100644 --- a/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp +++ b/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp @@ -95,7 +95,7 @@ public: .Seal().Build() ); - if (const auto useCoro = State_->Configuration->SourceCoroActor.Get(); useCoro && *useCoro && !s3ReadObject.Object().Format().Ref().IsAtom({"raw", "json_list"})) + if (const auto useCoro = State_->Configuration->SourceCoroActor.Get(); (!useCoro || *useCoro) && !s3ReadObject.Object().Format().Ref().IsAtom({"raw", "json_list"})) return Build<TDqSourceWrap>(ctx, read->Pos()) .Input<TS3ParseSettings>() .Paths(s3ReadObject.Object().Paths()) |