fix(control-plane): resume unstarted cadence reservations

loopx/control_plane/quota/automation_cadence.ts

@@ -143,10 +143,8 @@ export async function admitAutomationStart(p: JsonObject): Promise<JsonObject> {
     }
     if (held !== undefined) {
       // Same identity, no durable host attempt: keep the original interval anchor.
-      return manual === null && current.eligible_now !== true
-        ? {...current, admitted: false, reserved: false, reason: "minimum_interval_wait"}
-        : {...current, admitted: true, reserved: true, resumed: true,
-          reason: "resumed_unstarted_reservation"};
+      return {...current, admitted: true, reserved: true, resumed: true,
+        reason: "resumed_unstarted_reservation"};
     }
     if (manual === null && current.eligible_now !== true) {
       return {...current, admitted: false, reserved: false, reason: "minimum_interval_wait"};

tests/control_plane_ts/automation_cadence.test.ts

@@ -130,8 +130,8 @@ test("an unconfirmed reservation resumes while a confirmed start fails closed",
     await manage({...base, operation: "configure", expected_revision: 0, min_interval_minutes: 60,
       owner_reference: "owner-request", execute: true});
     assert.equal((await start("turn:1", 1000)).reserved, true);
-    assert.equal((await start("turn:1", 1000 + 3_600_000 - 1)).reason, "minimum_interval_wait");
-    const resumed = await start("turn:1", 1000 + 3_600_000);
+    assert.equal((await start("turn:2", 1001)).reason, "minimum_interval_wait");
+    const resumed = await start("turn:1", 1001, {trigger_at_ms: 1000});
     assert.equal(resumed.admitted, true);
     assert.equal(resumed.resumed, true);
     assert.equal(resumed.reason, "resumed_unstarted_reservation");

tests/test_loopx_turn_executor.py

@@ -1322,7 +1322,7 @@ def die_after_reservation(identity: Mapping[str, object]) -> dict[str, object]:
     assert calls == {"host": 0, "writeback": 0, "spend": 0, "scheduler": 0}
 
     started_at_ms = int(_cadence_starts(runtime_root)[0]["started_at_ms"])
-    monkeypatch.setattr(turn_cadence, "time", _FrozenTurnClock(started_at_ms + 120_000))
+    monkeypatch.setattr(turn_cadence, "time", _FrozenTurnClock(started_at_ms + 1))
     restart = _managed_cadence(runtime_root)
     recovered = run_loopx_turn_once(
         plan, admit_start=restart.admit, confirm_start=restart.confirm, **common
@@ -1368,7 +1368,7 @@ def die_before_attempt_record(path: Path, journal: dict[str, object]) -> None:
     assert calls == {"host": 0, "writeback": 0, "spend": 0, "scheduler": 0}
 
     started_at_ms = int(_cadence_starts(runtime_root)[0]["started_at_ms"])
-    monkeypatch.setattr(turn_cadence, "time", _FrozenTurnClock(started_at_ms + 120_000))
+    monkeypatch.setattr(turn_cadence, "time", _FrozenTurnClock(started_at_ms + 1))
     restart = _managed_cadence(runtime_root)
     recovered = run_loopx_turn_once(
         plan, admit_start=restart.admit, confirm_start=restart.confirm, **common