()
| 84 | |
| 85 | |
| 86 | def test_complete_and_fail(): |
| 87 | reg = RuntimeTaskRegistry() |
| 88 | s1 = _register(reg) |
| 89 | complete_workflow_task(s1.id, result={"ok": 1}, registry=reg) |
| 90 | done = reg.get(s1.id) |
| 91 | assert done.status == "completed" |
| 92 | assert done.result == {"ok": 1} |
| 93 | assert done.end_time is not None |
| 94 | assert done.evict_after is not None |
| 95 | |
| 96 | s2 = _register(reg) |
| 97 | fail_workflow_task(s2.id, error="boom", registry=reg) |
| 98 | assert reg.get(s2.id).status == "failed" |
| 99 | assert reg.get(s2.id).error == "boom" |
| 100 | |
| 101 | |
| 102 | def test_kill_aborts_the_run(): |
nothing calls this directly
no test coverage detected