Skip to content

[FEAT] Streaming Callback for Sequential Workflow #1081

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Open
wants to merge 13 commits into
base: master
Choose a base branch
from
Open

[FEAT] Streaming Callback for Sequential Workflow #1081

wants to merge 13 commits into from

Conversation

@aparekh02
Copy link
Contributor

@aparekh02 aparekh02 commented Sep 13, 2025 •
edited
Loading

DEMO: https://www.loom.com/share/94233587645848aa9747adc6e56710d0

📚 Documentation preview 📚: https://swarms--1081.org.readthedocs.build/en/1081/

@github-actions github-actions bot added the documentation Improvements or additions to documentation label Sep 15, 2025
github-advanced-security[bot]
github-advanced-security bot found potential problems Sep 20, 2025
View reviewed changes
swarms/structs/agent_rearrange.py
f"[SUCCESS] Agent {agent_name} completed task successfully"
)

self.conversation.add(role=agent_name, content=output)

Check failure

Code scanning / Pyre

Uninitialized local Error

Uninitialized local [61]: Local variable agent_name is undefined, or not always defined.
swarms/structs/agent_rearrange.py
f"[SUCCESS] Agent {agent_name} completed task successfully"
)

self.conversation.add(role=agent_name, content=output)

Check failure

Code scanning / Pyre

Uninitialized local Error

Uninitialized local [61]: Local variable output is undefined, or not always defined.
swarms/structs/agent_rearrange.py
Comment on lines +464 to +466
streaming_callback(
agent_name, chunk, False
)

Check failure

Code scanning / Pyre

Call error Error

Call error [29]: Optional[typing.Callable[[str, str, bool], None]] is not a function.
swarms/structs/sequential_workflow.py
max_loops=self.max_loops,
output_type=self.output_type,
team_awareness=self.team_awareness,
streaming_callback=self.streaming_callback,

Check failure

Code scanning / Pyre

Incompatible parameter type Error

Incompatible parameter type [6]: In call AgentRearrange.__init__, for argument streaming_callback, expected Optional[typing.Callable[[str], None]] but got Optional[typing.Callable[[str, str, bool], None]].
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

documentation Improvements or additions to documentation structs

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

[FEAT][Add Streaming Callbacks to SequentialWorkflow]

1 participant

@aparekh02