Skip to content
This repository was archived by the owner on Jan 27, 2026. It is now read-only.

Commit 792d424

Browse files
authored
Fix/k8s helm health (#363)
* fix k8s processor not getting health requests
1 parent c443293 commit 792d424

3 files changed

Lines changed: 9 additions & 7 deletions

File tree

crates/orchestrator/src/plugins/node_groups/mod.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,7 @@ impl NodeGroupsPlugin {
248248
let mut total_available = healthy_nodes.len();
249249

250250
for config in &available_configurations {
251-
println!("Checking configuration: {:?}", config);
251+
debug!("Checking configuration: {:?}", config);
252252
while total_available >= config.min_group_size {
253253
let initial_available = total_available;
254254

@@ -347,14 +347,18 @@ impl NodeGroupsPlugin {
347347
let mut interval = tokio::time::interval(Duration::from_secs(duration));
348348

349349
loop {
350+
let start = std::time::Instant::now();
350351
interval.tick().await;
352+
351353
if let Err(e) = self.try_form_new_groups() {
352354
error!("Error in group management: {}", e);
353355
}
354356
if let Some(heartbeats) = &self.node_groups_heartbeats {
355357
heartbeats.update_node_groups();
356358
}
357-
log::info!("Group management loop completed");
359+
360+
let elapsed = start.elapsed();
361+
log::info!("Group management loop completed in {:?}", elapsed);
358362
}
359363
}
360364

crates/shared/src/models/node.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ impl FromStr for ComputeRequirements {
306306
Ok(requirements)
307307
}
308308
}
309-
use log::info;
309+
use log::{debug, info};
310310

311311
impl ComputeSpecs {
312312
/// Checks if the current compute specs meet the given requirements.
@@ -354,7 +354,7 @@ impl ComputeSpecs {
354354
if !requirements.gpu.is_empty() {
355355
// Requirements specify GPUs, so the node must have a GPU spec...
356356
let Some(spec_gpu) = &self.gpu else {
357-
info!("GPU requirements not met: GPU required but none available");
357+
debug!("GPU requirements not met: GPU required but none available");
358358
return false;
359359
};
360360
// ...and that GPU spec must meet *at least one* of the requirement options.
@@ -363,7 +363,7 @@ impl ComputeSpecs {
363363
.iter()
364364
.any(|req_gpu| spec_gpu.meets(req_gpu))
365365
{
366-
info!("GPU requirements not met");
366+
debug!("GPU requirements not met");
367367
return false;
368368
}
369369
}

deployment/k8s/orchestrator-chart/templates/orchestrator-deployment.yaml

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
{{- define "orchestrator.container" }}
22
- name: {{ .root.Values.name | default "orchestrator" }}
33
image: {{ .root.Values.image }}
4-
{{- if .api }}
54
ports:
65
- containerPort: 8090
76
readinessProbe:
@@ -16,7 +15,6 @@
1615
port: 8090
1716
initialDelaySeconds: 15
1817
periodSeconds: 20
19-
{{- end }}
2018
resources:
2119
requests:
2220
memory: "256Mi"

0 commit comments

Comments
 (0)