feldera
diff --git a/‎crates/feldera-types/src/error.rs‎
Lines changed: 7 additions & 0 deletions b/‎crates/feldera-types/src/error.rs‎
Lines changed: 7 additions & 0 deletions
diff --git a/‎crates/pipeline-manager/src/api/main.rs‎
Lines changed: 3 additions & 1 deletion b/‎crates/pipeline-manager/src/api/main.rs‎
Lines changed: 3 additions & 1 deletion
diff --git a/‎crates/pipeline-manager/src/integration_test.rs‎
Lines changed: 4 additions & 10 deletions b/‎crates/pipeline-manager/src/integration_test.rs‎
Lines changed: 4 additions & 10 deletions
diff --git a/‎crates/pipeline-manager/src/runner/error.rs‎
Lines changed: 2 additions & 2 deletions b/‎crates/pipeline-manager/src/runner/error.rs‎
Lines changed: 2 additions & 2 deletions
@@ -68,6 +68,13 @@ impl ErrorResponse {
                 response.error_code,
                 response.message
             );
+        } else if error.status_code() == StatusCode::SERVICE_UNAVAILABLE {
+            info!(
+                "[HTTP error] {} {}: {}",
+                error.status_code(),
+                response.error_code,
+                response.message
+            );
         } else {
             // All other status responses should not occur in the implementation,
             // and thus are logged as errors. Many of the implementation errors are
 
@@ -345,7 +345,9 @@ pub fn log_response(
                 } else {
                     Level::Debug
                 }
-            } else if response.status().is_client_error() {
+            } else if response.status().is_client_error()
+                || response.status() == StatusCode::SERVICE_UNAVAILABLE
+            {
                 Level::Info
             } else {
                 Level::Error
 
@@ -58,6 +58,7 @@ use crate::config::PgEmbedConfig;
 use crate::db::storage_postgres::StoragePostgres;
 use crate::db::types::program::{CompilationProfile, ProgramConfig, ProgramStatus};
 use crate::runner::local_runner::LocalRunner;
+use crate::runner::pipeline_executor::LOGS_END_MESSAGE;
 use crate::{
     config::{ApiServerConfig, CompilerConfig, DatabaseConfig, LocalRunnerConfig},
     db::types::pipeline::PipelineStatus,
@@ -2685,20 +2686,13 @@ async fn pipeline_logs() {
     assert_eq!(response_logs_running.status(), StatusCode::OK);
     let logs1 = String::from_utf8(response_logs_paused.body().await.unwrap().to_vec()).unwrap();
     let logs2 = String::from_utf8(response_logs_running.body().await.unwrap().to_vec()).unwrap();
-    // It might take time for the logs to become available or upon shutdown they become
-    // no longer available, as such any of these three endings is possible
+    let normal_ending = format!("{}\n", LOGS_END_MESSAGE);
     assert!(
-        logs1.ends_with("LOG STREAM END: pipeline is being shutdown\n")
-            || logs1.ends_with("LOG STREAM END: stdout and stderr are finished\n")
-            || logs1.ends_with("LOG STREAM END: no longer available, please try again later\n")
-            || logs1.ends_with("LOG STREAM UNAVAILABLE: please try again later\n"),
+        logs1.ends_with(&normal_ending),
         "Unexpected logs ending: {logs1}"
     );
     assert!(
-        logs2.ends_with("LOG STREAM END: pipeline is being shutdown\n")
-            || logs2.ends_with("LOG STREAM END: stdout and stderr are finished\n")
-            || logs2.ends_with("LOG STREAM END: no longer available, please try again later\n")
-            || logs2.ends_with("LOG STREAM UNAVAILABLE: please try again later\n"),
+        logs2.ends_with(&normal_ending),
         "Unexpected logs ending: {logs2}"
     );
 
 
@@ -237,10 +237,10 @@ impl Display for RunnerError {
                 )
             }
             Self::RunnerDeploymentProvisionError { error } => {
-                write!(f, "Deployment provisioning failed: {error}")
+                write!(f, "Deployment provision operation failed: {error}")
             }
             Self::RunnerDeploymentCheckError { error } => {
-                write!(f, "Deployment check failed: {error}")
+                write!(f, "Deployment check failed: one or more deployment resources encountered a fatal error.\n\n{error}")
             }
             Self::RunnerDeploymentShutdownError { error } => {
                 write!(f, "Deployment shutdown failed (will retry): {error}")
Original file line number	Diff line number	Diff line change
`@@ -237,10 +237,10 @@ impl Display for RunnerError {`
`237`	`237`	`)`
`238`	`238`	`}`
`239`	`239`	`Self::RunnerDeploymentProvisionError { error } => {`
`240`		`- write!(f, "Deployment provisioning failed: {error}")`
	`240`	`+ write!(f, "Deployment provision operation failed: {error}")`
`241`	`241`	`}`
`242`	`242`	`Self::RunnerDeploymentCheckError { error } => {`
`243`		`- write!(f, "Deployment check failed: {error}")`
	`243`	`+ write!(f, "Deployment check failed: one or more deployment resources encountered a fatal error.\n\n{error}")`
`244`	`244`	`}`
`245`	`245`	`Self::RunnerDeploymentShutdownError { error } => {`
`246`	`246`	`write!(f, "Deployment shutdown failed (will retry): {error}")`