diff --git a/swarms/structs/agent_rearrange.py b/swarms/structs/agent_rearrange.py index 38184375..6480cb14 100644 --- a/swarms/structs/agent_rearrange.py +++ b/swarms/structs/agent_rearrange.py @@ -387,7 +387,7 @@ class AgentRearrange: for agent_name in agent_names: agent = self.agents[agent_name] # Set agent.streaming_on if no streaming_callback - if self.streaming_callback is None: + if self.streaming_callback is not None: agent.streaming_on = True result = agent.run( task=self.conversation.get_str(), @@ -437,7 +437,7 @@ class AgentRearrange: ) # Set agent.streaming_on if no streaming_callback - if self.streaming_callback is None: + if self.streaming_callback is not None: agent.streaming_on = True current_task = agent.run( task=self.conversation.get_str(), diff --git a/swarms/structs/sequential_workflow.py b/swarms/structs/sequential_workflow.py index 6fe586ba..c1de30a9 100644 --- a/swarms/structs/sequential_workflow.py +++ b/swarms/structs/sequential_workflow.py @@ -95,6 +95,7 @@ class SequentialWorkflow: max_loops=self.max_loops, output_type=self.output_type, team_awareness=self.team_awareness, + streaming_callback=self.streaming_callback, *args, **kwargs, )