Clean the state of workflow using the model.
(self)
| 868 | self.workflow_state.update(state) |
| 869 | |
| 870 | async def clean_workflow_state(self) -> None: |
| 871 | """Clean the state of workflow using the model.""" |
| 872 | async with self.state_lock: |
| 873 | self.workflow_state = {} |
| 874 | self.history.clear() |
| 875 | |
| 876 | async def shutdown(self) -> None: |
| 877 | """Shutdown all underlying model actors cleanly.""" |
no outgoing calls
no test coverage detected