()
| 127 | |
| 128 | |
| 129 | async def test_task_adapter_kill(): |
| 130 | reg = RuntimeTaskRegistry() |
| 131 | run = _FakeRun() |
| 132 | state = _register(reg, run=run) |
| 133 | await LocalWorkflowTask().kill(state.id, reg) |
| 134 | assert reg.get(state.id).status == "killed" |
| 135 | assert run.controller.aborted_with == "workflow_stopped" |
| 136 | |
| 137 | |
| 138 | def test_terminal_transitions_are_idempotent(): |
nothing calls this directly
no test coverage detected