fix

ydb-platform · Jul 26, 2024 · b74adfe · b74adfe
1 parent 84565d1
commit b74adfe
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/cmd/ydbcp/main.go b/cmd/ydbcp/main.go
@@ -316,10 +316,11 @@ func main() {
 		xlog.Error(ctx, "Error init DBConnector", zap.Error(err))
 		os.Exit(1)
 	}
+	clientConnector := client.NewClientYdbConnector(configInstance.ClientConnection)
 
 	server := server{
 		driver:     dbConnector,
-		clientConn: client.NewClientYdbConnector(),
+		clientConn: clientConnector,
 		s3:         configInstance.S3,
 	}
 	defer server.driver.Close(ctx)
@@ -341,7 +342,7 @@ func main() {
 
 	handlersRegistry := processor.NewOperationHandlerRegistry()
 	err = handlersRegistry.Add(
-		types.OperationTypeTB, handlers.MakeTBOperationHandler(dbConnector, client.NewClientYdbConnector()),
+		types.OperationTypeTB, handlers.MakeTBOperationHandler(dbConnector, clientConnector),
 	)
 	if err != nil {
 		xlog.Error(ctx, "failed to register TB handler", zap.Error(err))
@@ -350,7 +351,7 @@ func main() {
 
 	err = handlersRegistry.Add(
 		types.OperationTypeRB,
-		handlers.MakeRBOperationHandler(dbConnector, client.NewClientYdbConnector(), configInstance),
+		handlers.MakeRBOperationHandler(dbConnector, clientConnector, configInstance),
 	)
 
 	if err != nil {