Create an error result.
(
cls,
error: str,
execution_id: str | None = None,
workflow_id: str | None = None,
pipeline_id: str | None = None,
message: str = "Execution failed",
)
| 152 | |
| 153 | @classmethod |
| 154 | def error( |
| 155 | cls, |
| 156 | error: str, |
| 157 | execution_id: str | None = None, |
| 158 | workflow_id: str | None = None, |
| 159 | pipeline_id: str | None = None, |
| 160 | message: str = "Execution failed", |
| 161 | ) -> "SchedulerExecutionResult": |
| 162 | """Create an error result.""" |
| 163 | return cls( |
| 164 | status=SchedulerExecutionStatus.ERROR, |
| 165 | execution_id=execution_id, |
| 166 | workflow_id=workflow_id, |
| 167 | pipeline_id=pipeline_id, |
| 168 | message=message, |
| 169 | error=error, |
| 170 | ) |
| 171 | |
| 172 | |
| 173 | @dataclass |
no outgoing calls