diff --git a/src/io/pipeline.rs b/src/io/pipeline.rs
index 4e65f54..b277513 100644
--- a/src/io/pipeline.rs
+++ b/src/io/pipeline.rs
@@ -178,13 +178,13 @@ impl<I: Send + 'static, R: Send + 'static> Pipeline<I, R> {
                                 }
                             }
                             Err(e) => {
-                                first_err = Some(e);
                                 if debug_enabled() {
                                     tracing::debug!(
                                         "Pipeline: apply error, stopping, err={:?}",
                                         e
                                     );
                                 }
+                                first_err = Some(e);
                             }
                         }