Skip to content

Fix WMQ examples (75-77) - #492

Merged
mp-orkes merged 3 commits into
mainfrom
fix/wmq-examples
Aug 14, 2026
Merged

Fix WMQ examples (75-77)#492
mp-orkes merged 3 commits into
mainfrom
fix/wmq-examples

Conversation

@mp-orkes

@mp-orkes mp-orkes commented Aug 14, 2026

Copy link
Copy Markdown
Contributor

Tested WMQ & Agent examples:

  • 75 — docstring claimed the agent loops forever; main() ends it with handle.stop().
  • 76stop() fired right after the last send_message, so the third task was pulled but never answered. Now waits before stopping.
  • 77 — crashed on worker spawn (no if __name__ == "__main__" guard); added it plus a Ctrl+C that stops the agent.

Ran each against a local OSS server with WMQ enabled. 76 now answers all 3 tasks (_stop_requested: true, COMPLETED); 77 echoes produced records ([le_random_topic@0] hello).

🤖 Generated with Claude Code

mp-orkes and others added 3 commits August 13, 2026 22:16
Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Comment thread examples/agents/75_wait_for_message.py
Comment thread examples/agents/76_wait_for_message_streaming.py
Comment thread examples/agents/77_kafka_consumer_agent.py
@mp-orkes
mp-orkes marked this pull request as ready for review August 14, 2026 01:21
@mp-orkes
mp-orkes merged commit d5db0e0 into main Aug 14, 2026
6 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants