File tree Expand file tree Collapse file tree 2 files changed +13
-9
lines changed
nexus/reconfigurator/execution/src Expand file tree Collapse file tree 2 files changed +13
-9
lines changed Original file line number Diff line number Diff line change @@ -92,8 +92,11 @@ pub(crate) async fn deploy_nodes(
92
92
let log = log. new ( slog:: o!( "admin_url" => admin_url. clone( ) ) ) ;
93
93
futs. push ( Either :: Left ( async move {
94
94
let client = Client :: new ( & admin_url, log. clone ( ) ) ;
95
- client. generate_keeper_config ( & config) . await . map ( |_| ( ) ) . map_err (
96
- |e| {
95
+ client
96
+ . generate_keeper_config_and_enable ( & config)
97
+ . await
98
+ . map ( |_| ( ) )
99
+ . map_err ( |e| {
97
100
anyhow ! (
98
101
concat!(
99
102
"failed to send config for clickhouse keeper " ,
@@ -104,8 +107,7 @@ pub(crate) async fn deploy_nodes(
104
107
admin_url,
105
108
e
106
109
)
107
- } ,
108
- )
110
+ } )
109
111
} ) ) ;
110
112
}
111
113
for config in server_configs {
@@ -119,8 +121,11 @@ pub(crate) async fn deploy_nodes(
119
121
let log = opctx. log . new ( slog:: o!( "admin_url" => admin_url. clone( ) ) ) ;
120
122
futs. push ( Either :: Right ( async move {
121
123
let client = Client :: new ( & admin_url, log. clone ( ) ) ;
122
- client. generate_server_config ( & config) . await . map ( |_| ( ) ) . map_err (
123
- |e| {
124
+ client
125
+ . generate_server_config_and_enable ( & config)
126
+ . await
127
+ . map ( |_| ( ) )
128
+ . map_err ( |e| {
124
129
anyhow ! (
125
130
concat!(
126
131
"failed to send config for clickhouse server " ,
@@ -131,8 +136,7 @@ pub(crate) async fn deploy_nodes(
131
136
admin_url,
132
137
e
133
138
)
134
- } ,
135
- )
139
+ } )
136
140
} ) ) ;
137
141
}
138
142
You can’t perform that action at this time.
0 commit comments