Create and return a logger instance.
(self)
| 119 | raise WorkflowCancelledError(message, workflow_id=self.graph.name) |
| 120 | |
| 121 | def _create_logger(self) -> WorkflowLogger: |
| 122 | """Create and return a logger instance.""" |
| 123 | return WorkflowLogger(self.graph.name, self.graph.log_level) |
| 124 | |
| 125 | @classmethod |
| 126 | def execute_graph( |