|
|
@@ -465,9 +465,6 @@ class FakeSaddle:
|
|
|
self.suspend_on_title = None # this task (by title) parks as suspended
|
|
|
self.output_seq = 100 # daemon-global entry ids for pushed results
|
|
|
self.last_activity_epoch = int(time.time())
|
|
|
- self.subtask_status_events = [] # recorded /task-update subtask-status payloads
|
|
|
- self.subtask_fail_hits = 0 # delivery attempts that 500ed (fail_subtask_status)
|
|
|
- self.fail_subtask_status = False # exercise the web's retry path
|
|
|
self.hang_next = {} # path suffix -> hang count (never responds)
|
|
|
self.abort_failures = 0 # cancel task-updates failing (500) while > 0
|
|
|
self.abort_log = [] # task ids aborted via task-update cancel
|
|
|
@@ -775,9 +772,9 @@ class FakeSaddle:
|
|
|
self._send(409, {"error": "no block is waiting for an answer — parks resume via allocation"})
|
|
|
return
|
|
|
if self.path == "/task-update":
|
|
|
- # Plan 10: cancel (abort machinery), comment (injected
|
|
|
- # turn) and subtask-status (live subtask set) — delivered
|
|
|
- # directly to a RUNNING daemon, no auth.
|
|
|
+ # Plan 10: cancel (abort machinery) and comment
|
|
|
+ # (injected turn) — delivered directly to a RUNNING
|
|
|
+ # daemon, no auth.
|
|
|
try:
|
|
|
payload = json.loads(raw)
|
|
|
except ValueError:
|
|
|
@@ -801,13 +798,6 @@ class FakeSaddle:
|
|
|
elif kind == "comment":
|
|
|
self.daemon.comment_log.append(payload)
|
|
|
self._send(200, {"ok": True})
|
|
|
- elif kind == "subtask-status":
|
|
|
- if self.daemon.fail_subtask_status:
|
|
|
- self.daemon.subtask_fail_hits += 1
|
|
|
- self._send(500, {"error": "simulated failure"})
|
|
|
- return
|
|
|
- self.daemon.subtask_status_events.append(payload)
|
|
|
- self._send(200, {"ok": True})
|
|
|
else:
|
|
|
self._send(400, {"error": "unknown task-update kind"})
|
|
|
return
|