feat: more percise error handling

Author: raphael-goetz

src/sagittarius/retry.rs

@@ -71,14 +71,10 @@ pub async fn create_channel_with_retry(
                 retries += 1;
 
                 if retries >= MAX_RETRIES {
-                    log::error!(
+                    panic!(
                         "Sagittarius connection retries exhausted channel={} url={} attempts={} last_error={:?}",
-                        channel_name,
-                        url,
-                        MAX_RETRIES,
-                        err
+                        channel_name, url, MAX_RETRIES, err
                     );
-                    panic!("Reached max retries to url {}", url)
                 }
             }
         }

src/startup/dynamic_mode.rs

@@ -170,6 +170,7 @@ pub async fn run(
         result = &mut server_task => {
             match result {
                 Ok(()) => log::warn!("gRPC server task exited unexpectedly; shutting down"),
+                Err(err) if err.is_panic() => {}
                 Err(err) => log::error!("gRPC server task failed; shutting down error={:?}", err),
             }
             flow_task.abort();
@@ -178,6 +179,7 @@ pub async fn run(
         result = &mut test_execution_task => {
             match result {
                 Ok(()) => log::warn!("Test execution stream task exited unexpectedly; shutting down"),
+                Err(err) if err.is_panic() => {}
                 Err(err) => log::error!("Test execution stream task failed; shutting down error={:?}", err),
             }
             server_task.abort();
@@ -186,6 +188,7 @@ pub async fn run(
         result = &mut flow_task => {
             match result {
                 Ok(()) => log::warn!("Flow stream task exited unexpectedly; shutting down"),
+                Err(err) if err.is_panic() => {}
                 Err(err) => log::error!("Flow stream task failed; shutting down error={:?}", err),
             }
             server_task.abort();

src/startup/mod.rs

@@ -30,7 +30,6 @@ pub async fn run(
             client
         }
         Err(err) => {
-            log::error!("Failed to connect to NATS: {:?}", err);
             panic!("Failed to connect to NATS server: {:?}", err)
         }
     };
@@ -61,12 +60,10 @@ pub async fn run(
             Arc::new(kv)
         }
         Err(err) => {
-            log::error!(
+            panic!(
                 "Failed to open NATS key-value store bucket={} error={:?}",
-                config.nats.bucket,
-                err
-            );
-            panic!("Failed to get key-value store: {:?}", err)
+                config.nats.bucket, err
+            )
         }
     };
 

src/startup/static_mode.rs

@@ -68,6 +68,7 @@ pub async fn run(
         result = &mut server_task => {
             match result {
                 Ok(()) => log::warn!("gRPC server task exited unexpectedly; shutting down"),
+                Err(err) if err.is_panic() => {}
                 Err(err) => log::error!("gRPC server task failed; shutting down error={:?}", err),
             }
         }