Improved error message

STFC-ICD-Research-and-Design · Nov 29, 2024 · 143c120 · 143c120
1 parent 007d31e
commit 143c120
Showing 1 changed file with 3 additions and 8 deletions.
diff --git a/trace-to-events/src/main.rs b/trace-to-events/src/main.rs
@@ -152,14 +152,9 @@ async fn main() -> anyhow::Result<()> {
                 }
                 Err(e) => warn!("Kafka error: {}", e)
             },
-            r = kafka_producer_thread_set.join_next() => {
-                if let Some(r) = r {
-                    match r {
-                        Ok(_) => {}
-                        Err(e) => {
-                            error!("{e}");
-                        }
-                    }
+            join_next = kafka_producer_thread_set.join_next() => {
+                if let Some(Err(e)) = join_next {
+                    error!("Error Joining Kafka Producer Task: {e}");
                 }
             }
         }