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
..
2026-04-18 00:24:44 -07:00
2026-05-04 08:32:24 -07:00
2026-04-18 00:24:44 -07:00
2026-04-30 07:01:10 -07:00
2026-05-09 22:16:11 +00:00
2026-04-18 00:24:44 -07:00
2026-05-05 17:31:45 -07:00
2026-05-11 02:49:32 +00:00
2026-05-05 02:26:35 -07:00
2026-05-05 09:52:15 -07:00
2026-05-11 02:47:21 +00:00
2026-05-11 02:16:09 +00:00
2026-05-10 03:46:59 -07:00
2026-05-05 09:50:47 -07:00
2026-05-05 13:26:49 -07:00
2026-05-05 14:28:58 -07:00
2026-05-05 13:59:58 -07:00
2026-05-05 09:50:39 -07:00
2026-05-05 09:50:47 -07:00
2026-04-24 19:54:43 -07:00
2026-05-05 04:43:16 -07:00
2026-05-03 01:18:19 -07:00
2026-04-30 06:27:20 -07:00
2026-04-27 16:43:32 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-05-04 14:59:56 -07:00
2026-05-04 14:15:27 -07:00
2026-04-18 00:24:44 -07:00
2026-05-10 02:38:14 -07:00
2026-05-01 13:07:55 -07:00
2026-04-18 00:24:44 -07:00
2026-05-04 16:30:26 -07:00
2026-04-28 17:11:36 -07:00
2026-05-05 17:21:28 -07:00
2026-04-28 17:11:36 -07:00
2026-05-04 16:29:54 -07:00
2026-05-03 00:17:12 -07:00
2026-04-18 00:24:44 -07:00
2026-05-02 00:58:05 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-04-26 22:58:21 -07:00
2026-05-03 01:01:57 -07:00
2026-04-18 00:24:44 -07:00
2026-05-05 12:34:41 -07:00
2026-05-05 11:47:14 -07:00
2026-05-01 11:47:53 -07:00
2026-04-29 15:19:02 -07:00
2026-04-27 12:40:11 -07:00
2026-05-03 01:30:05 -07:00
2026-04-18 00:24:44 -07:00
2026-05-09 21:55:29 +00:00
2026-05-05 15:07:15 -07:00
2026-05-05 04:33:06 -07:00
2026-05-09 21:55:29 +00:00
2026-05-05 13:25:06 -07:00
2026-04-28 17:11:36 -07:00
2026-04-27 11:48:05 -07:00
2026-04-18 00:24:44 -07:00
2026-05-04 10:22:31 -07:00
2026-04-18 00:24:44 -07:00
2026-04-30 08:41:42 -07:00
2026-05-01 13:07:55 -07:00
2026-05-01 13:07:55 -07:00
2026-04-28 20:42:15 -07:00
2026-04-24 01:42:13 +00:00
2026-04-18 00:38:55 -07:00
2026-04-18 00:24:44 -07:00
2026-04-21 12:40:44 +00:00
2026-05-04 12:20:34 -07:00
2026-05-04 16:30:26 -07:00
2026-04-18 00:24:44 -07:00
2026-04-26 22:38:01 -07:00
2026-04-30 07:01:10 -07:00
2026-05-01 18:31:21 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-05-05 13:25:06 -07:00
2026-05-04 15:07:53 -07:00
2026-04-18 00:24:44 -07:00
2026-04-28 14:10:29 -07:00
2026-04-30 06:27:20 -07:00
2026-04-27 01:57:43 -07:00
2026-04-27 02:04:26 -07:00
2026-05-01 18:01:51 -07:00
2026-04-19 00:32:42 -07:00
2026-04-18 00:24:44 -07:00
2026-04-18 00:24:44 -07:00
2026-05-09 20:51:48 +00:00
2026-04-18 00:24:44 -07:00