Skip to content

Commit 26c3e90

Browse files
authored
feat: do not run Flux version checker if remote updates are disabled (#1586)
1 parent 2c7b8fd commit 26c3e90

File tree

1 file changed

+10
-6
lines changed
  • agent-control/src/agent_control/run

1 file changed

+10
-6
lines changed

agent-control/src/agent_control/run/k8s.rs

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -203,6 +203,8 @@ impl AgentControlRunner {
203203
// The http server stops on Drop. We need to keep it while the agent control is running.
204204
let _http_server = self.http_server_runner.map(Runner::start);
205205

206+
let cd_remote_updates_enabled = self.k8s_config.cd_remote_update;
207+
206208
let health_checker_builder = agent_control_health_checker_builder(
207209
k8s_client.clone(),
208210
self.k8s_config.namespace.to_string(),
@@ -220,12 +222,14 @@ impl AgentControlRunner {
220222
);
221223
let (agent_control_internal_publisher, agent_control_internal_consumer) = pub_sub();
222224

223-
let _cd_version_checker = start_cd_version_checker(
224-
k8s_client,
225-
self.k8s_config.namespace.clone(),
226-
self.k8s_config.cd_release_name.clone(),
227-
agent_control_internal_publisher.clone(),
228-
);
225+
let _cd_version_checker = cd_remote_updates_enabled.then(|| {
226+
start_cd_version_checker(
227+
k8s_client,
228+
self.k8s_config.namespace.clone(),
229+
self.k8s_config.cd_release_name.clone(),
230+
agent_control_internal_publisher.clone(),
231+
)
232+
});
229233

230234
AgentControl::new(
231235
maybe_client,

0 commit comments

Comments
 (0)