diff --git a/crates/cli/src/messenger_variant.rs b/crates/cli/src/messenger_variant.rs
index 670d4239f..2560537a8 100644
--- a/crates/cli/src/messenger_variant.rs
+++ b/crates/cli/src/messenger_variant.rs
@@ -142,10 +142,16 @@ impl<'a> WorkflowMessenger for MessengerVariant<'a> {
     ) -> anyhow::Result<()> {
         // This is meant to match what we do in the CLI server
         let level = VisibilityLevels::Debug;
+
         match self {
             MessengerVariant::Formatted(_)
             | MessengerVariant::Transformed(_)
-            | MessengerVariant::JsonLine(_) => self.emit(&message.result, &level),
+            | MessengerVariant::JsonLine(_) => {
+                // For local emitters,, we will also apply rewrites
+                self.emit(&message.result, &level)?;
+                self.apply_rewrite(&message.result, &level)?;
+                Ok(())
+            }
             #[cfg(feature = "remote_redis")]
             MessengerVariant::Redis(m) => m.emit_from_workflow(message),
             #[cfg(feature = "remote_pubsub")]
diff --git a/crates/marzano_messenger/src/workflows.rs b/crates/marzano_messenger/src/workflows.rs
index e0fe2f553..528ed8b1e 100644
--- a/crates/marzano_messenger/src/workflows.rs
+++ b/crates/marzano_messenger/src/workflows.rs
@@ -3,7 +3,7 @@ use std::path::PathBuf;
 use marzano_core::api::MatchResult;
 use serde::{Deserialize, Serialize};
 
-use crate::emit::{Messager};
+use crate::emit::Messager;
 
 #[derive(Deserialize, Serialize, Debug)]
 pub struct PackagedWorkflowOutcome {