| 269 | |
| 270 | |
| 271 | class LocalWorkflowTask: |
| 272 | name: str = "LocalWorkflowTask" |
| 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__ = [ |
no outgoing calls