diff --git a/CHANGELOG.md b/CHANGELOG.md
index ee43fad6c..f99864d10 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -72,7 +72,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   removed in a future version. Use the `/start` endpoint in its place. In the
   meantime, both endpoints work and deliver equivalent functionality.
 
-- Added `source` field to `ErrorFrame` to indicate `FrameProcessor` that generated the error.
+- Added `processor` field to `ErrorFrame` to indicate `FrameProcessor` that generated the error.
 
 ## [0.0.77] - 2025-07-31
 
diff --git a/src/pipecat/frames/frames.py b/src/pipecat/frames/frames.py
index 6ee7a858c..30f8eb7b4 100644
--- a/src/pipecat/frames/frames.py
+++ b/src/pipecat/frames/frames.py
@@ -657,7 +657,7 @@ class ErrorFrame(SystemFrame):
 
     error: str
     fatal: bool = False
-    source: Optional["FrameProcessor"] = None
+    processor: Optional["FrameProcessor"] = None
 
     def __str__(self):
         return f"{self.name}(error: {self.error}, fatal: {self.fatal})"
diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py
index ac053007f..e6611a161 100644
--- a/src/pipecat/processors/frame_processor.py
+++ b/src/pipecat/processors/frame_processor.py
@@ -494,8 +494,8 @@ class FrameProcessor(BaseObject):
         Args:
             error: The error frame to push.
         """
-        if not error.source:
-            error.source = self
+        if not error.processor:
+            error.processor = self
         await self.push_frame(error, FrameDirection.UPSTREAM)
 
     async def push_frame(self, frame: Frame, direction: FrameDirection = FrameDirection.DOWNSTREAM):