diff options
author | dinmukhammed <dinmukhammed@yandex-team.ru> | 2022-02-11 12:05:03 +0300 |
---|---|---|
committer | dinmukhammed <dinmukhammed@yandex-team.ru> | 2022-02-11 12:05:03 +0300 |
commit | 432e645033ef49cb72384ba055652b2668ec73fd (patch) | |
tree | c17098bf4f5b1293a70c11703b7e300caec5bbed | |
parent | 40a7214ee0ade2d35b5a1757c23879ff41eb9056 (diff) | |
download | ydb-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.cpp | 8 |
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()); |