diff --git a/binaries/daemon/src/lib.rs b/binaries/daemon/src/lib.rs index 1d1274f8..b635d758 100644 --- a/binaries/daemon/src/lib.rs +++ b/binaries/daemon/src/lib.rs @@ -1258,8 +1258,8 @@ impl Daemon { NodeErrorCause::Cascading { caused_by_node } } None if grace_duration_kill => NodeErrorCause::GraceDuration, - None => NodeErrorCause::Other { - stderr: dataflow + None => { + let cause = dataflow .and_then(|d| d.node_stderr_most_recent.get(&node_id)) .map(|queue| { let mut s = if queue.is_full() { @@ -1272,8 +1272,14 @@ impl Daemon { } s }) - .unwrap_or_default(), - }, + .unwrap_or_default(); + + tracing::error!("node {dataflow_id}/{node_id} failed with:"); + for line in cause.lines() { + tracing::error!(" {}", line); + } + NodeErrorCause::Other { stderr: cause } + } }; Err(NodeError { timestamp: self.clock.new_timestamp(),