From 1a92081725814ca0a5ca452bf0cee17a9ac08f6d Mon Sep 17 00:00:00 2001
From: zimoyin <2556608754@qq.com>
Date: Sat, 10 Jan 2026 18:04:10 +0800
Subject: [PATCH] =?UTF-8?q?fix(pipeline):=20=E7=A7=BB=E9=99=A4=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E5=A4=84=E7=90=86=E5=99=A8=E4=B8=AD=E7=9A=84=E9=94=99?=
 =?UTF-8?q?=E8=AF=AFyield=E8=AF=AD=E5=8F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 解决流中异常返回
---
 pipeline/pipeline.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/pipeline/pipeline.py b/pipeline/pipeline.py
index b87189d..e06bfd7 100644
--- a/pipeline/pipeline.py
+++ b/pipeline/pipeline.py
@@ -63,7 +63,6 @@ class Pipeline:
             for processor in self.processors:
                 try:
                     data = processor.process(data)
-                    yield data
                 except Exception as e:
                     self.logger.error(f"同步处理器 {processor.name} 执行出错: {e}")