pending fetcher has been fixed

ref:8254e50a9a10dba62928748b4e9e93853df5f121

1 files changed, 13 insertions, 7 deletions

diff --git a/ydb/core/yq/libs/actors/pending_fetcher.cpp b/ydb/core/yq/libs/actors/pending_fetcher.cpp
index 20c03c9b370..fa9afa27854 100644
--- a/ydb/core/yq/libs/actors/pending_fetcher.cpp
+++ b/ydb/core/yq/libs/actors/pending_fetcher.cpp
@@ -269,14 +269,20 @@ private:
         Client
             .GetTask(std::move(request))
             .Subscribe([actorSystem, selfId](const NThreading::TFuture<TGetTaskResult>& future) {
-                const auto& wrappedResult = future.GetValue();
-                if (wrappedResult.IsResultSet()) {
+                try {
+                    const auto& wrappedResult = future.GetValue();
+                    if (wrappedResult.IsResultSet()) {
+                        actorSystem->Send(selfId, new TEvPrivate::TEvGetTaskInternalResponse(
+                            wrappedResult.IsSuccess(), wrappedResult.GetIssues(), wrappedResult.GetResult())
+                        );
+                    } else {
+                        actorSystem->Send(selfId, new TEvPrivate::TEvGetTaskInternalResponse(
+                            false, TIssues{{TIssue{"grpc private api result is not set for get task call"}}}, Yq::Private::GetTaskResult{})
+                        );
+                    }
+                } catch (...) {
                     actorSystem->Send(selfId, new TEvPrivate::TEvGetTaskInternalResponse(
-                        wrappedResult.IsSuccess(), wrappedResult.GetIssues(), wrappedResult.GetResult())
-                    );
-                } else {
-                    actorSystem->Send(selfId, new TEvPrivate::TEvGetTaskInternalResponse(
-                        false, TIssues{{TIssue{"grpc private api result is not set for get task call"}}}, Yq::Private::GetTaskResult{})
+                        false, TIssues{{TIssue{CurrentExceptionMessage()}}}, Yq::Private::GetTaskResult{})
                     );
                 }
             });