aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorOleg Doronin <dorooleg@yandex.ru>2024-10-18 18:41:27 +0200
committerGitHub <noreply@github.com>2024-10-18 19:41:27 +0300
commit93e2e233dbb15879f54885174b20f258260cd2a8 (patch)
tree11643f1f83ca5c4b344c85c9664dd53838b51bfc
parentf5d549eaec28919a2fe2ae0740ab9a25d3232027 (diff)
downloadydb-93e2e233dbb15879f54885174b20f258260cd2a8.tar.gz
compute id has been supported (#9556)
-rw-r--r--ydb/core/fq/libs/compute/ydb/control_plane/compute_database_control_plane_service.cpp2
-rw-r--r--ydb/core/fq/libs/config/protos/compute.proto2
2 files changed, 3 insertions, 1 deletions
diff --git a/ydb/core/fq/libs/compute/ydb/control_plane/compute_database_control_plane_service.cpp b/ydb/core/fq/libs/compute/ydb/control_plane/compute_database_control_plane_service.cpp
index f5abb10cfb..60ed347d82 100644
--- a/ydb/core/fq/libs/compute/ydb/control_plane/compute_database_control_plane_service.cpp
+++ b/ydb/core/fq/libs/compute/ydb/control_plane/compute_database_control_plane_service.cpp
@@ -289,7 +289,7 @@ public:
void FillRequest(TEvYdbCompute::TEvCreateDatabaseRequest::TPtr& ev, const NConfig::TComputeDatabaseConfig& config) {
NYdb::NFq::TScope scope(ev.Get()->Get()->Scope);
ev.Get()->Get()->BasePath = config.GetControlPlaneConnection().GetDatabase();
- const TString databaseName = Config.GetYdb().GetControlPlane().GetDatabasePrefix() + scope.ParseFolder();
+ const TString databaseName = TStringBuilder{} << Config.GetYdb().GetControlPlane().GetDatabasePrefix() << (config.GetId() ? config.GetId() + "_" : TString{}) << scope.ParseFolder();
ev.Get()->Get()->Path = config.GetTenant() ? config.GetTenant() + "/" + databaseName: databaseName;
}
diff --git a/ydb/core/fq/libs/config/protos/compute.proto b/ydb/core/fq/libs/config/protos/compute.proto
index d8b0d1022f..7ce620b59e 100644
--- a/ydb/core/fq/libs/config/protos/compute.proto
+++ b/ydb/core/fq/libs/config/protos/compute.proto
@@ -43,6 +43,7 @@ message TWorkloadManagerConfig {
}
message TComputeDatabaseConfig {
+ string Id = 7;
TYdbStorageConfig ControlPlaneConnection = 1;
TYdbStorageConfig SchemeConnection = 6;
TYdbStorageConfig ExecutionConnection = 3;
@@ -58,6 +59,7 @@ message TDatabaseMapping {
message TYdbComputeControlPlane {
message TSingle {
+ string Id = 3;
TYdbStorageConfig Connection = 1;
TWorkloadManagerConfig WorkloadManagerConfig = 2;
}