Suffix pod cron with .c

Small cleanup
skateco · Aug 4, 2024 · 9945359 · 9945359
1 parent 0d2a08b
commit 9945359
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/src/executor.rs b/src/executor.rs
@@ -81,6 +81,7 @@ impl DefaultExecutor {
         let mut pod = Pod::default();
         pod.spec = pod_template_spec.spec;
         pod.metadata = cron_job.metadata.clone();
+        pod.metadata.name = Some(format!("{}.c", ns_name.to_string()));
         let mut_spec = pod.spec.as_mut().unwrap();
         mut_spec.restart_policy = Some("Never".to_string());
 

diff --git a/src/refresh.rs b/src/refresh.rs
@@ -38,17 +38,18 @@ pub async fn refresh(args: RefreshArgs) -> Result<(), Box<dyn Error>> {
     let state = refreshed_state(&cluster.name, &clients, &config).await.expect("failed to refresh state");
 
     for node in &(state.nodes) {
-        match node.status {
+        let emoji = match node.status {
             NodeStatus::Unhealthy => {
-                println!("node {} {} - {} ", node.node_name, node.status, CROSS_EMOJI)
+                CROSS_EMOJI
             }
             NodeStatus::Healthy => {
-                println!("node {} {} - {} ", node.node_name, node.status, CHECKBOX_EMOJI)
+                CHECKBOX_EMOJI
             }
             NodeStatus::Unknown => {
-                println!("node {} {} - {} ", node.node_name, node.status, '?')
+                ' '
             }
         };
+        println!("node {} {} - {} ", node.node_name, node.status, emoji)
     }
 
     state.persist()

diff --git a/src/scheduler.rs b/src/scheduler.rs
@@ -215,7 +215,6 @@ impl DefaultScheduler {
             let mut labels = meta.labels.unwrap_or_default();
             labels.insert("skate.io/deployment".to_string(), d.metadata.name.as_ref().unwrap().clone());
             labels.insert("skate.io/replica".to_string(), i.to_string());
-            meta.labels = Some(labels.clone());
             meta.labels = Some(labels);
 
             let pod = Pod {