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}")