molecule-core/workspace
Molecule AI Core-BE 99f3cf7c8f [core-be-agent] fix(#354): wire delegation-results consumer into a2a executor
Close the A2A delegation auto-resume gap.

Root cause: heartbeat.py's _check_delegations already writes completed
delegation rows to DELEGATION_RESULTS_FILE and sends a self-message to
wake the agent. executor_helpers.read_delegation_results() was defined to
atomically consume that file, but a2a_executor._core_execute() never
called it — so delegation results were written but the agent never saw
them.

Fix: call read_delegation_results() at the top of _core_execute() and
prepend the results to the user input context so the agent can act on
them without an explicit check_task_status call. The Temporal durable
workflow path is also covered because it calls _core_execute() directly.

Test: two new cases — delegation results injected when file exists;
user input passed through unchanged when file is empty.

Closes molecule-core#354.
2026-05-11 02:49:32 +00:00
..
adapters
builtin_tools
lib
molecule_audit
platform_tools
plugins_registry
policies
scripts
skill_loader
tests
_sanitize_a2a.py
.coveragerc
a2a_cli.py
a2a_client.py
a2a_executor.py
a2a_mcp_server.py
a2a_response.py
a2a_tools_delegation.py
a2a_tools_inbox.py
a2a_tools_memory.py
a2a_tools_messaging.py
a2a_tools_rbac.py
a2a_tools.py
adapter_base.py
agent.py
agents_md.py
boot_routes.py
build-all.sh
card_helpers.py
config.py
configs_dir.py
consolidation.py
coordinator.py
Dockerfile
entrypoint.sh
event_log.py
events.py
executor_helpers.py
heartbeat.py
inbox_uploads.py
inbox.py
initial_prompt.py
internal_chat_uploads.py
internal_file_read.py
main.py
mcp_cli.py
mcp_doctor.py
mcp_heartbeat.py
mcp_inbox_pollers.py
mcp_workspace_resolver.py
molecule_ai_status.py
not_configured_handler.py
platform_auth.py
platform_inbound_auth.py
plugins.py
preflight.py
prompt.py
pytest.ini
rebuild-runtime-images.sh
requirements.txt
runtime_wedge.py
secret_redactor.py
shared_runtime.py
smoke_mode.py
transcript_auth.py
watcher.py