aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authordinmukhammed <dinmukhammed@yandex-team.ru>2022-02-11 12:05:03 +0300
committerdinmukhammed <dinmukhammed@yandex-team.ru>2022-02-11 12:05:03 +0300
commit432e645033ef49cb72384ba055652b2668ec73fd (patch)
treec17098bf4f5b1293a70c11703b7e300caec5bbed
parent40a7214ee0ade2d35b5a1757c23879ff41eb9056 (diff)
downloadydb-432e645033ef49cb72384ba055652b2668ec73fd.tar.gz
Set correct error message
Correct error message ref:8ee06811079471890b6bcff5f2ec52e75dc20da5
-rw-r--r--ydb/core/yq/libs/db_resolver/db_async_resolver_impl.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/ydb/core/yq/libs/db_resolver/db_async_resolver_impl.cpp b/ydb/core/yq/libs/db_resolver/db_async_resolver_impl.cpp
index fb0e2d9789f..62cc1eac90e 100644
--- a/ydb/core/yq/libs/db_resolver/db_async_resolver_impl.cpp
+++ b/ydb/core/yq/libs/db_resolver/db_async_resolver_impl.cpp
@@ -17,15 +17,15 @@ TDatabaseAsyncResolver::TDatabaseAsyncResolver(
NThreading::TFuture<TEvents::TDbResolverResponse> TDatabaseAsyncResolver::ResolveIds(const TResolveParams& params) const {
auto promise = NThreading::NewPromise<TEvents::TDbResolverResponse>();
+ TDuration timeout = TDuration::Seconds(20);
auto callback = MakeHolder<NYql::TRichActorFutureCallback<TEvents::TEvEndpointResponse>>(
[promise] (TAutoPtr<NActors::TEventHandle<TEvents::TEvEndpointResponse>>& event) mutable {
promise.SetValue(std::move(event->Get()->DbResolverResponse));
},
- [promise] () mutable {
- //TODO add logs
- promise.SetException("Error occurred on resolving ids. Message was undelivered.");
+ [promise, timeout] () mutable {
+ promise.SetException("Couldn't resolve database ids for " + timeout.ToString() + " seconds");
},
- TDuration::Seconds(10)
+ timeout
);
NActors::TActorId callbackId = ActorSystem->Register(callback.Release());