Record the workflow start event.
(self, workflow_config: Dict[str, Any] = None)
| 307 | ) |
| 308 | |
| 309 | def record_workflow_start(self, workflow_config: Dict[str, Any] = None) -> None: |
| 310 | """Record the workflow start event.""" |
| 311 | self.info( |
| 312 | "Workflow execution started", |
| 313 | event_type=EventType.WORKFLOW_START, |
| 314 | details={ |
| 315 | "workflow_id": self.workflow_id, |
| 316 | "node_count": workflow_config.get("node_count") if workflow_config else None, |
| 317 | "edge_count": workflow_config.get("edge_count") if workflow_config else None, |
| 318 | } |
| 319 | ) |
| 320 | |
| 321 | def record_workflow_end(self, success: bool = True, |
| 322 | duration: float = None, details: Dict[str, Any] = None) -> None: |