(self, workflow_instance: Workflow)
| 120 | return self.workflow_instance |
| 121 | |
| 122 | async def _run_workflow(self, workflow_instance: Workflow) -> List[Experience]: |
| 123 | if workflow_instance.asynchronous: |
| 124 | exps = await workflow_instance.run_async() |
| 125 | else: |
| 126 | exps = workflow_instance.run() |
| 127 | return exps |
| 128 | |
| 129 | def _create_isolated_workflow_instance(self, task: Task) -> Workflow: |
| 130 | return task.to_workflow( |
no test coverage detected