Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/import_generation.txt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
21
22
2 changes: 1 addition & 1 deletion .github/last_commit.txt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
362cf04ca2b49a71004ea0558dbf5a041db0e0c6
a1abe1a8139be6a6188d79503a63aa2e5068c6c1
3 changes: 0 additions & 3 deletions src/client/federated_topic/impl/federation_observer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -136,16 +136,13 @@ void TFederatedDbObserverImpl::OnFederationDiscovery(TStatus&& status, Ydb::Fede
<< "OnFederationDiscovery fall back to single mode, database=" << DbDriverState_->Database);
FederatedDbState->Status = TPlainStatus{}; // SUCCESS
FederatedDbState->ControlPlaneEndpoint = DbDriverState_->DiscoveryEndpoint;
auto dbState = Connections_->GetDriverState(std::nullopt, std::nullopt, std::nullopt, std::nullopt, std::nullopt);
FederatedDbState->ControlPlaneEndpoint = dbState->DiscoveryEndpoint;
// FederatedDbState->SelfLocation = ???;
auto db = std::make_shared<Ydb::FederationDiscovery::DatabaseInfo>();
db->set_path(TStringType{DbDriverState_->Database});
db->set_endpoint(TStringType{DbDriverState_->DiscoveryEndpoint});
db->set_status(Ydb::FederationDiscovery::DatabaseInfo_Status_AVAILABLE);
db->set_weight(100);
FederatedDbState->DbInfos.emplace_back(std::move(db));

} else {
if (status.IsSuccess()) {
ScheduleFederationDiscoveryImpl(REDISCOVERY_DELAY);
Expand Down
Loading