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

Commit e09b38a

Browse files
authored
orchestrator log cleanup (#394)
* remove print statements from orchestrator
1 parent c88a30e commit e09b38a

4 files changed

Lines changed: 3 additions & 17 deletions

File tree

crates/orchestrator/src/api/routes/nodes.rs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,6 @@ async fn get_nodes(query: Query<NodeQuery>, app_state: Data<AppState>) -> HttpRe
7373
}
7474

7575
async fn restart_node_task(node_id: web::Path<String>, app_state: Data<AppState>) -> HttpResponse {
76-
println!("restart_node_task: {}", node_id);
7776
let node_address = Address::from_str(&node_id).unwrap();
7877
let node = app_state.store_context.node_store.get_node(&node_address);
7978
match node {
@@ -208,7 +207,6 @@ async fn get_node_logs(node_id: web::Path<String>, app_state: Data<AppState>) ->
208207
}
209208

210209
async fn get_node_metrics(node_id: web::Path<String>, app_state: Data<AppState>) -> HttpResponse {
211-
println!("get_node_metrics: {}", node_id);
212210
let node_address = Address::from_str(&node_id).unwrap();
213211
let metrics = app_state
214212
.store_context
@@ -360,7 +358,6 @@ mod tests {
360358

361359
let body = test::read_body(resp).await;
362360
let json: serde_json::Value = serde_json::from_slice(&body).unwrap();
363-
println!("json {:?}", json);
364361
assert_eq!(
365362
json["success"], true,
366363
"Expected success to be true but got {:?}",

crates/orchestrator/src/metrics/mod.rs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,6 @@ impl MetricsContext {
3232
label: &str,
3333
value: f64,
3434
) {
35-
println!("record_compute_task_gauge: {:?}", node_address);
36-
let vals = vec![node_address, task_id, label, &self.pool_id];
37-
println!("vals: {:?}", vals);
3835
self.compute_task_gauges
3936
.with_label_values(&[node_address, task_id, label, &self.pool_id])
4037
.set(value);

crates/orchestrator/src/status_update/mod.rs

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -68,18 +68,12 @@ impl NodeStatusUpdater {
6868

6969
#[cfg(not(test))]
7070
async fn is_node_in_pool(&self, node: &OrchestratorNode) -> bool {
71-
let node_in_pool: bool = match self
71+
let node_in_pool: bool = (self
7272
.contracts
7373
.compute_pool
7474
.is_node_in_pool(self.pool_id, node.address)
75-
.await
76-
{
77-
Result::Ok(result) => result,
78-
Result::Err(e) => {
79-
println!("Error checking if node is in pool: {}", e);
80-
false
81-
}
82-
};
75+
.await)
76+
.unwrap_or(false);
8377
node_in_pool
8478
}
8579

crates/orchestrator/src/store/domains/metrics_store.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,6 @@ impl MetricsStore {
122122
result.insert(clean_key.to_string(), total);
123123
}
124124

125-
println!("result {:?}", result);
126125
result
127126
}
128127

@@ -131,7 +130,6 @@ impl MetricsStore {
131130
let all_keys: Vec<String> = con
132131
.keys(format!("{}:*:*", ORCHESTRATOR_METRICS_STORE))
133132
.unwrap();
134-
println!("all_keys {:?}", all_keys);
135133

136134
let tasks = all_keys
137135
.iter()

0 commit comments

Comments
 (0)