Skip to content

Commit

Permalink
Fixed typo
Browse files Browse the repository at this point in the history
  • Loading branch information
GrigoriyPA committed Sep 25, 2024
1 parent 5ae39b9 commit 55189fc
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions ydb/core/kqp/proxy_service/kqp_proxy_service.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -642,7 +642,7 @@ class TKqpProxyService : public TActorBootstrapped<TKqpProxyService> {
NYql::IssuesToMessage(issues, response->Record.GetRef().MutableResponse()->MutableQueryIssues());
Send(sender, std::move(response));
};
if (!DatabasesCache.SetDatabaseIdOrDeffer(ev, errorHandler, ActorContext())) {
if (!DatabasesCache.SetDatabaseIdOrDefer(ev, errorHandler, ActorContext())) {
return;
}

Expand Down Expand Up @@ -1650,7 +1650,7 @@ class TKqpProxyService : public TActorBootstrapped<TKqpProxyService> {
const auto errorHandler = [this, sender = ev->Sender](Ydb::StatusIds::StatusCode status, NYql::TIssues issues){
Send(sender, new TResponse(status, std::move(issues)));
};
if (!DatabasesCache.SetDatabaseIdOrDeffer(ev, errorHandler, ActorContext())) {
if (!DatabasesCache.SetDatabaseIdOrDefer(ev, errorHandler, ActorContext())) {
return false;
}

Expand Down
2 changes: 1 addition & 1 deletion ydb/core/kqp/proxy_service/kqp_proxy_service_impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -659,7 +659,7 @@ class TDatabasesCache {
TDatabasesCache(TDuration idleTimeout = TDuration::Seconds(60));

template <typename TEvent>
bool SetDatabaseIdOrDeffer(TEvent& event, std::function<void(Ydb::StatusIds::StatusCode, NYql::TIssues)> errorHandler, TActorContext actorContext) {
bool SetDatabaseIdOrDefer(TEvent& event, std::function<void(Ydb::StatusIds::StatusCode, NYql::TIssues)> errorHandler, TActorContext actorContext) {
if (!event->Get()->GetDatabaseId().empty()) {
return true;
}
Expand Down
2 changes: 1 addition & 1 deletion ydb/core/kqp/proxy_service/kqp_proxy_ut.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ class TDatabaseCacheTestActor : public TActorBootstrapped<TDatabaseCacheTestActo
}

void Handle(TEvKqp::TEvQueryRequest::TPtr& ev) {
auto success = Cache.SetDatabaseIdOrDeffer(ev, [this](Ydb::StatusIds::StatusCode status, NYql::TIssues issues) {
auto success = Cache.SetDatabaseIdOrDefer(ev, [this](Ydb::StatusIds::StatusCode status, NYql::TIssues issues) {
UNIT_ASSERT_C(false, TStringBuilder() << "Unexpected fail, status: " << status << ", " << GetErrorString() << issues.ToString());
}, ActorContext());

Expand Down

0 comments on commit 55189fc

Please sign in to comment.