diff options
| author | udovichenko-r <rvu@ydb.tech> | 2023-12-08 15:01:53 +0300 |
|---|---|---|
| committer | udovichenko-r <rvu@ydb.tech> | 2023-12-08 16:52:41 +0300 |
| commit | aa0ed015dee9afdcd2050ef74742121a8880df91 (patch) | |
| tree | ca446e7b8e1568a5ea1eeec3f381bce6e6700960 | |
| parent | 9a5a56cfbd85bc517d9979ae246b447298d8f9b4 (diff) | |
| download | ydb-aa0ed015dee9afdcd2050ef74742121a8880df91.tar.gz | |
[yql] Don't ignore async results
| -rw-r--r-- | ydb/library/yql/core/facade/yql_facade.cpp | 2 | ||||
| -rw-r--r-- | ydb/library/yql/core/facade/yql_facade.h | 3 |
2 files changed, 4 insertions, 1 deletions
diff --git a/ydb/library/yql/core/facade/yql_facade.cpp b/ydb/library/yql/core/facade/yql_facade.cpp index 77d958d103..1971f63511 100644 --- a/ydb/library/yql/core/facade/yql_facade.cpp +++ b/ydb/library/yql/core/facade/yql_facade.cpp @@ -1179,7 +1179,7 @@ TFuture<IGraphTransformer::TStatus> TProgram::AsyncTransformWithFallback(bool ap source->Reset(); } TypeCtx_->Reset(); - CleanupLastSession(); + CleanupLastSession().GetValueSync(); std::function<void(const TIssuePtr& issue)> toInfo = [&](const TIssuePtr& issue) { if (issue->Severity == TSeverityIds::S_ERROR diff --git a/ydb/library/yql/core/facade/yql_facade.h b/ydb/library/yql/core/facade/yql_facade.h index 5252ba2d0f..4d7830b3cb 100644 --- a/ydb/library/yql/core/facade/yql_facade.h +++ b/ydb/library/yql/core/facade/yql_facade.h @@ -186,6 +186,7 @@ public: bool HasActiveProcesses(); bool NeedWaitForActiveProcesses(); + [[nodiscard]] NThreading::TFuture<void> Abort(); inline TIssues Issues() { @@ -362,7 +363,9 @@ private: NThreading::TFuture<void> OpenSession(const TString& username); + [[nodiscard]] NThreading::TFuture<void> CleanupLastSession(); + [[nodiscard]] NThreading::TFuture<void> CloseLastSession(); TFutureStatus RemoteKikimrValidate(const TString& cluster); |