fix: use SOURCE_ERROR in streaming runner commit-failure path

CHANGELOG.md

@@ -7,6 +7,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Fixed
+- Streaming runner crashed with a secondary `AttributeError: ERROR` when `source.commit()` raised, because `PipelineReturnStatus.ERROR` does not exist on the enum. The error branch now uses `PipelineReturnStatus.SOURCE_ERROR`, matching the convention used in `producer.py`, so the runner reports a clean Failure status instead of hiding the real commit error behind an enum lookup.
+
 ## [0.3.11] - 2026-04-17
 
 ### Fixed

bizon/engine/runner/adapters/streaming.py

@@ -165,8 +165,8 @@ def run(self) -> RunnerStatus:
                         source.commit()
                     except Exception as e:
                         logger.error(f"Error committing source: {e}")
-                        monitor.track_pipeline_status(PipelineReturnStatus.ERROR)
-                        return RunnerStatus(stream=PipelineReturnStatus.ERROR)
+                        monitor.track_pipeline_status(PipelineReturnStatus.SOURCE_ERROR)
+                        return RunnerStatus(stream=PipelineReturnStatus.SOURCE_ERROR)
 
                 iteration += 1