[FEAT] [TEST] [DOCS] Streaming Callback for Majority Voting

[aparekh02]

• Description: NEW feature that introduces custom streaming to the consensus agent with agents running concurrently.
• Issue: Resolves [FEAT][Add Streaming Callbacks to MajorityVoting] #1061
• DEMO: https://www.loom.com/share/c56897ab606c4b6782f905acb45e54c0

---

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

[cursor]

This PR is being reviewed by Cursor Bugbot

Details

You are on the Bugbot Free tier. On this plan, Bugbot will review limited PRs each billing cycle.

To receive Bugbot reviews on all of your PRs, visit the Cursor dashboard to activate Pro and start your 14-day free trial.

---

Bug: Undefined Variable Causes Test Failure

The test_streaming_majority_voting function asserts majority_vote is not None, but majority_vote is never defined within its scope. This causes a NameError at runtime, likely a leftover from refactored test logic.

tests/structs/test_majority_voting.py#L201-L203

swarms/tests/structs/test_majority_voting.py

Lines 201 to 203 in e839dc5

	# Assert majority vote is correct
	assert majority_vote is not None

 

---

Bug: Consensus Streaming Callback Never Signals Completion

The consensus_streaming_callback in MajorityVoting.run always passes is_final=False to the user's callback. This means the user's callback is never notified when the consensus agent's streaming output is complete, which can prevent final output flushing or cleanup.

swarms/structs/majority_voting.py#L210-L222

swarms/swarms/structs/majority_voting.py

Lines 210 to 222 in e839dc5

	if streaming_callback is not None:
	def consensus_streaming_callback(chunk: str):
	"""Wrapper for consensus agent streaming callback."""
	try:
	if chunk is not None and chunk.strip():
	streaming_callback(consensus_agent_name, chunk, False)
	except Exception as callback_error:
	if self.verbose:
	logger.warning(
	f"[STREAMING] Callback failed for {consensus_agent_name}: {str(callback_error)}"
	)
	else:
	consensus_streaming_callback = None

 

---