nas/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-11-05 06:39:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(agent): queue steering input during active runs

Browse Source
This commit is contained in:
jxxghp
2026-09-11 05:17:37 +08:00
parent 66d288ffc2
commit abd3cea92b
20 changed files with 1158 additions and 186 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/agent/tools/impl/execute_command.py
View File

@@ -615,7 +615,11 @@ class ExecuteCommandTool(MoviePilotTool):
{wait_task, scope_task}, timeout=normalized_timeout,
return_when=asyncio.FIRST_COMPLETED,
)
scope_cancelled = scope_task in done
# The scope can be sealed in the same event-loop turn after
# ``wait_task`` wins. Recheck the authoritative owner state so
# a run that crossed the cancellation boundary never reports
# an unqualified success.
scope_cancelled = scope_task in done or scope.closed
if wait_task not in done:
timed_out = not scope_cancelled
await self._cleanup_process(process, wait_task)