diff --git a/CHANGELOG.md b/CHANGELOG.md
index 22eb0b29e..c553c292a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -6,6 +6,8 @@
 ### Improvements
 ### Bugfix
 
+* fixes unbound local error in http input connector 
+
 ## 13.1.1
 ### Improvements
 
diff --git a/logprep/framework/pipeline.py b/logprep/framework/pipeline.py
index 1d7a35ea6..b41ce94af 100644
--- a/logprep/framework/pipeline.py
+++ b/logprep/framework/pipeline.py
@@ -267,6 +267,8 @@ def process_pipeline(self) -> PipelineResult:
                 self.logger.error(",".join((str(error) for error in result.errors)))
                 self._store_failed_event(result.errors, result.event_received, event)
                 return
+        else:
+            return PipelineResult(results=[], event=event, pipeline=[], event_received=event)
         if self._output:
             if self._pipeline:
                 result_data = [res.data for res in result if res.data]