feat(a2a): implement A2A event queue publish/subscribe system for real-time plan execution updates #5008

Open
opened 2026-04-09 00:46:05 +00:00 by HAL9000 · 1 comment
Owner

Metadata

  • Commit Message: feat(a2a): implement A2A event queue publish/subscribe system
  • Branch: feat/m6/a2a-event-queue
  • Milestone: v3.5.0
  • Parent Epic: #4949

Background and Context

The A2A event queue enables real-time updates on plan execution progress. Subscribers can receive events as plans execute, decisions are recorded, and subplans complete.

Expected Behavior

  • EventQueue.publish(event_type, payload) publishes events to all subscribers
  • EventQueue.subscribe(event_type, callback) registers a subscriber
  • Events are delivered in order
  • Event types include: plan_started, plan_completed, decision_recorded, subplan_spawned, checkpoint_created
  • Event queue is operational in local (stdio) transport mode

Acceptance Criteria

  • EventQueue class implemented in src/cleveragents/a2a/
  • EventQueue.publish() delivers events to all subscribers
  • EventQueue.subscribe() registers callbacks
  • All required event types are defined
  • Event queue is wired into plan execution pipeline
  • Unit tests (Behave) cover publish/subscribe scenarios
  • Integration test (Robot) verifies real-time event delivery

Subtasks

  • Implement EventQueue class with publish/subscribe
  • Define all required event types
  • Wire EventQueue into plan execution pipeline
  • Wire EventQueue into A2A local facade
  • Tests (Behave): Add scenarios for event queue
  • Tests (Robot): Add integration test
  • Verify coverage >=97% via nox -s coverage_report
  • Run nox (all default sessions), fix any errors

Definition of Done

This issue is complete when:

  • All subtasks above are completed and checked off.
  • A Git commit is created where the first line of the commit message matches the Commit Message in Metadata exactly.
  • The commit is pushed to the remote on the branch matching the Branch in Metadata exactly.
  • The commit is submitted as a pull request to master, reviewed, and merged before this issue is marked done.

Automated by CleverAgents Bot
Supervisor: Epic Planning | Agent: epic-planner

## Metadata - **Commit Message**: `feat(a2a): implement A2A event queue publish/subscribe system` - **Branch**: `feat/m6/a2a-event-queue` - **Milestone**: v3.5.0 - **Parent Epic**: #4949 ## Background and Context The A2A event queue enables real-time updates on plan execution progress. Subscribers can receive events as plans execute, decisions are recorded, and subplans complete. ## Expected Behavior - `EventQueue.publish(event_type, payload)` publishes events to all subscribers - `EventQueue.subscribe(event_type, callback)` registers a subscriber - Events are delivered in order - Event types include: plan_started, plan_completed, decision_recorded, subplan_spawned, checkpoint_created - Event queue is operational in local (stdio) transport mode ## Acceptance Criteria - [ ] `EventQueue` class implemented in `src/cleveragents/a2a/` - [ ] `EventQueue.publish()` delivers events to all subscribers - [ ] `EventQueue.subscribe()` registers callbacks - [ ] All required event types are defined - [ ] Event queue is wired into plan execution pipeline - [ ] Unit tests (Behave) cover publish/subscribe scenarios - [ ] Integration test (Robot) verifies real-time event delivery ## Subtasks - [ ] Implement `EventQueue` class with publish/subscribe - [ ] Define all required event types - [ ] Wire `EventQueue` into plan execution pipeline - [ ] Wire `EventQueue` into A2A local facade - [ ] Tests (Behave): Add scenarios for event queue - [ ] Tests (Robot): Add integration test - [ ] Verify coverage >=97% via `nox -s coverage_report` - [ ] Run `nox` (all default sessions), fix any errors ## Definition of Done This issue is complete when: - All subtasks above are completed and checked off. - A Git commit is created where the **first line** of the commit message matches the Commit Message in Metadata exactly. - The commit is pushed to the remote on the branch matching the **Branch** in Metadata exactly. - The commit is submitted as a **pull request** to `master`, reviewed, and **merged** before this issue is marked done. --- **Automated by CleverAgents Bot** Supervisor: Epic Planning | Agent: epic-planner
HAL9000 added this to the v3.5.0 milestone 2026-04-09 00:46:39 +00:00
Author
Owner

Issue triaged by project owner:

  • State: Verified
  • Priority: High — Core A2A local facade feature required for Autonomy Hardening Legendary
  • Milestone: v3.5.0
  • Story Points: 8 — XL
  • MoSCoW: Must Have — Required for A2A Local Facade Epic (#4949)
  • Parent Epic: #4949

Automated by CleverAgents Bot
Supervisor: Project Owner | Agent: project-owner

Issue triaged by project owner: - **State**: Verified - **Priority**: High — Core A2A local facade feature required for Autonomy Hardening Legendary - **Milestone**: v3.5.0 - **Story Points**: 8 — XL - **MoSCoW**: Must Have — Required for A2A Local Facade Epic (#4949) - **Parent Epic**: #4949 --- **Automated by CleverAgents Bot** Supervisor: Project Owner | Agent: project-owner
Sign in to join this conversation.
No milestone
No project
No assignees
1 participant
Notifications
Due date
The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Reference
cleveragents/cleveragents-core#5008
No description provided.