(self, task_id: str, registry: "RuntimeTaskRegistry")
| 273 | type: Literal["local_workflow"] = "local_workflow" |
| 274 | |
| 275 | async def kill(self, task_id: str, registry: "RuntimeTaskRegistry") -> None: |
| 276 | kill_workflow_task(task_id, registry) |
| 277 | |
| 278 | |
| 279 | __all__ = [ |
nothing calls this directly
no test coverage detected