Event Bus Topology¶
Every EventType published or subscribed in src/. Events with no subscribers are flagged ⚠️ (likely dead).
| Event | Publishers | Subscribers |
|---|---|---|
| ADR_DRAFT_OPENED ⚠️ | src.base_runner:BaseRunner._process_transcript_for_adr_draft |
— |
| AGENT_ACTIVITY ⚠️ | src.runner_utils:_stream_and_collect |
— |
| BACKGROUND_WORKER_STATUS ⚠️ | src.base_background_loop:BaseBackgroundLoop._execute_cycle |
— |
| BASELINE_UPDATE ⚠️ | src.baseline_policy:BaselinePolicy.check_approvalsrc.baseline_policy:BaselinePolicy.rollback |
— |
| CI_CHECK ⚠️ | src.pr_manager:PRManager.wait_for_cisrc.reviewer:ReviewRunner.fix_ci |
— |
| CRATE_ACTIVATED ⚠️ | src.crate_manager:CrateManager.activate_crate |
— |
| CRATE_COMPLETED ⚠️ | src.crate_manager:CrateManager.check_and_advance |
— |
| DIAGNOSTIC_UPDATE ⚠️ | src.diagnostic_loop:DiagnosticLoop._publish_update |
— |
| DISCOVER_UPDATE ⚠️ | src.discover_phase:DiscoverPhase._discover_single |
— |
| EPIC_PROGRESS ⚠️ | src.epic:EpicManager.refresh_cache |
— |
| EPIC_READY ⚠️ | src.epic:EpicManager._publish_ready_eventsrc.epic:EpicManager.refresh_cache |
— |
| EPIC_RELEASED ⚠️ | src.epic:EpicManager._execute_release |
— |
| EPIC_RELEASING ⚠️ | src.epic:EpicManager._execute_release |
— |
| EPIC_UPDATE ⚠️ | src.epic:EpicManager._publish_update |
— |
| ERROR ⚠️ | src.base_background_loop:BaseBackgroundLoop._execute_cyclesrc.orchestrator:HydraFlowOrchestrator._polling_loopsrc.orchestrator:HydraFlowOrchestrator._restart_loop |
— |
| HITL_ESCALATION ⚠️ | src.dashboard_routes._routes:create_router.request_changessrc.review_phase:ReviewPhase._escalate_to_hitl |
— |
| HITL_UPDATE ⚠️ | src.dashboard_routes._hitl_routes:register._resolve_hitl_itemsrc.dashboard_routes._hitl_routes:register.hitl_correctsrc.hitl_phase:HITLPhase._process_one_hitlsrc.hitl_runner:HITLRunner.runsrc.pr_unsticker:PRUnsticker.unstick |
— |
| ISSUE_CREATED ⚠️ | src.pr_manager:PRManager.create_issue |
— |
| MERGE_UPDATE ⚠️ | src.pr_manager:PRManager.merge_prsrc.pr_manager:PRManager.merge_promotion_pr |
— |
| METRICS_UPDATE ⚠️ | src.metrics_manager:MetricsManager.sync |
— |
| ORCHESTRATOR_STATUS ⚠️ | src.dashboard_routes._control_routes:register.start_orchestratorsrc.orchestrator:HydraFlowOrchestrator._publish_status |
— |
| PHASE_CHANGE ⚠️ | src.server:_run_with_dashboard |
— |
| PIPELINE_STATS ⚠️ | src.orchestrator:HydraFlowOrchestrator.emit_pipeline_stats |
— |
| PLANNER_UPDATE ⚠️ | src.planner:PlannerRunner._emit_status |
— |
| PR_CREATED ⚠️ | src.pr_manager:PRManager.create_prsrc.pr_manager:PRManager.create_promotion_pr |
— |
| QUEUE_UPDATE ⚠️ | src.issue_store:IssueStore._publish_queue_update_nowaitsrc.issue_store:IssueStore.refreshsrc.mockworld.fakes.fake_issue_store:FakeIssueStore.refresh |
— |
| REPORT_UPDATE ⚠️ | src.report_issue_loop:ReportIssueLoop._emit_report_event |
— |
| RETROSPECTIVE_UPDATE ⚠️ | src.retrospective_loop:RetrospectiveLoop._publish_update |
— |
| REVIEW_UPDATE ⚠️ | src.merge_conflict_resolver:MergeConflictResolver._publish_review_statussrc.phase_utils:publish_review_statussrc.reviewer:ReviewRunner.fix_review_findingssrc.reviewer:ReviewRunner.review |
— |
| SESSION_END ⚠️ | src.orchestrator:HydraFlowOrchestrator._end_session |
— |
| SESSION_START ⚠️ | src.orchestrator:HydraFlowOrchestrator._start_session |
— |
| SHAPE_UPDATE ⚠️ | src.shape_phase:ShapePhase._process_finalizationsrc.shape_phase:ShapePhase._run_council_votesrc.shape_phase:ShapePhase._shape_with_runner |
— |
| SYSTEM_ALERT ⚠️ | src.cost_budget_alerts:check_daily_budgetsrc.cost_budget_alerts:check_issue_costsrc.epic:EpicManager.check_stale_epicssrc.orchestrator:HydraFlowOrchestrator._deferred_pipeline_startsrc.orchestrator:HydraFlowOrchestrator._handle_auth_errorsrc.orchestrator:HydraFlowOrchestrator._pause_for_creditssrc.orchestrator:HydraFlowOrchestrator._polling_loopsrc.orchestrator:HydraFlowOrchestrator._resume_loops_after_credit_pausesrc.post_merge_handler:PostMergeHandler._safe_hooksrc.post_merge_handler:PostMergeHandler.handle_approved |
— |
| SYSTEM_REROUTE ⚠️ | src.review_phase:ReviewPhase._review_single_adrsrc.triage_phase:TriagePhase._triage_single_traced |
— |
| TRANSCRIPT_LINE ⚠️ | src.runner_utils:_stream_and_collectsrc.triage:TriageRunner._emit_transcript |
— |
| TRANSCRIPT_SUMMARY ⚠️ | src.transcript_summarizer:TranscriptSummarizer._summarize_and_comment_inner |
— |
| TRIAGE_UPDATE ⚠️ | src.triage:TriageRunner._emit_status |
— |
| VERIFICATION_JUDGE ⚠️ | src.verification_judge:VerificationJudge.judge |
— |
| VISUAL_GATE ⚠️ | src.post_merge_handler:PostMergeHandler._run_visual_gatesrc.review_phase:ReviewPhase._emit_visual_gate_telemetrysrc.review_phase:ReviewPhase.check_visual_gate |
— |
| WORKER_UPDATE ⚠️ | src.agent:AgentRunner._emit_status |
— |
Regenerated from commit 692dc64 on 2026-05-03 04:47 UTC. Source last changed at 692dc64. Status: 🟢 fresh.