|
|
|
@ -40,7 +40,6 @@ class AnswerStreamProcessor(StreamProcessor):
|
|
|
|
elif isinstance(event, NodeRunStreamChunkEvent):
|
|
|
|
elif isinstance(event, NodeRunStreamChunkEvent):
|
|
|
|
if event.in_iteration_id or event.in_loop_id:
|
|
|
|
if event.in_iteration_id or event.in_loop_id:
|
|
|
|
if self.has_output and event.node_id not in self.output_node_ids:
|
|
|
|
if self.has_output and event.node_id not in self.output_node_ids:
|
|
|
|
print(f"event22: {event}")
|
|
|
|
|
|
|
|
event.chunk_content = "\n" + event.chunk_content
|
|
|
|
event.chunk_content = "\n" + event.chunk_content
|
|
|
|
self.output_node_ids.add(event.node_id)
|
|
|
|
self.output_node_ids.add(event.node_id)
|
|
|
|
self.has_output = True
|
|
|
|
self.has_output = True
|
|
|
|
|