diff options
| author | stanly <stanly@yandex-team.com> | 2023-03-24 20:03:55 +0300 |
|---|---|---|
| committer | stanly <stanly@yandex-team.com> | 2023-03-24 20:03:55 +0300 |
| commit | 8d1337f3c063061366114a566c2b50fd3474b48c (patch) | |
| tree | 3c0e893a7fd469ccc2c14e5eb482a0fd7618dee5 | |
| parent | f4f85eb007c535f176eea61f60a57f005985f71b (diff) | |
| download | ydb-8d1337f3c063061366114a566c2b50fd3474b48c.tar.gz | |
really wait on infly futures
| -rw-r--r-- | ydb/public/lib/ydb_cli/import/import.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/public/lib/ydb_cli/import/import.cpp b/ydb/public/lib/ydb_cli/import/import.cpp index b83c53db166..69f85c9407a 100644 --- a/ydb/public/lib/ydb_cli/import/import.cpp +++ b/ydb/public/lib/ydb_cli/import/import.cpp @@ -114,7 +114,7 @@ namespace { TStatus WaitForQueue(std::deque<TAsyncStatus>& inFlightRequests, size_t maxQueueSize) { std::vector<TStatus> problemResults; while (!inFlightRequests.empty() && inFlightRequests.size() > maxQueueSize && problemResults.empty()) { - Y_UNUSED(NThreading::WaitAny(inFlightRequests)); + NThreading::WaitAny(inFlightRequests).Wait(); ui32 delta = 0; for (ui32 i = 0; i + delta < inFlightRequests.size();) { if (inFlightRequests[i].HasValue() || inFlightRequests[i].HasException()) { |