feat(orchestration): DAG TaskGraph + delegate bridge + A2A bus + reflex hints#12436
feat(orchestration): DAG TaskGraph + delegate bridge + A2A bus + reflex hints#12436georgex8001 wants to merge 11 commits into
Conversation
234dde8 to
117e288
Compare
91d6574 to
5231d67
Compare
cde4ffd to
8f274f0
Compare
|
Hey team, just performed a clean reset and force-push. My local tests for orchestration (tests/orchestration/test_task_graph.py) are passing with flying colors. However, I noticed the CI is currently failing on two fronts, which seem to be upstream issues: Tests: There are 50+ test errors mostly originating from tests/gateway/test_discord_*.py, test_web_server.py, etc. It looks like these failures are inherited directly from the latest main branch state (possibly recent refactors in the Discord mock). Supply Chain Audit: It fails with CRITICAL supply chain risk patterns detected, but the action bot couldn't post the details in the comments due to fork GITHUB_TOKEN being read-only. Could someone confirm if the main branch is currently unstable? And if possible, could a maintainer check the audit action logs and let me know which specific pattern in the orchestration diff triggered the false positive? I'll hold off on further changes until the baseline is green and we clarify the audit flag. Thanks! |
…ff PR comment non-blocking
…ache_key in httpx cache tests
Summary
Adds a new
orchestrationpackage undersrc/orchestration/:TaskGraph: DAG validation (cycle detection), parallel wave execution withasyncio, fail-fast propagation (dependents →SKIPPED).MultiAgentOrchestrator: orchestrates nodes via existingdelegate_task(thread offload withasyncio.to_thread), no edits todelegate_tool.py.AgentCommunicationBus: in-process async queue for Agent-to-Agent style messaging (wire to MCP transport can be layered on later).OrchestratorRegistry: hooks for custom coordinator factories.hermes_constants); state under$HERMES_HOME/orchestration/reflex_hints.jsonlviarecord_failure/load_recent_hints.Packaging
pyproject.toml:[tool.setuptools.packages.find]addswhere = [".", "src"]andorchestrationtoinclude(resolved againstorigin/mainduring cherry-pick).Tests