(
&self,
workflow: Workflow,
guardrail_enforcer: Option<Arc<Enforcer>>,
event_tx: Option<tokio::sync::mpsc::Sender<crate::stream::StreamEvent>>,
stream_mode: cr
| 339 | } |
| 340 | |
| 341 | pub async fn execute_with_context( |
| 342 | &self, |
| 343 | workflow: Workflow, |
| 344 | guardrail_enforcer: Option<Arc<Enforcer>>, |
| 345 | event_tx: Option<tokio::sync::mpsc::Sender<crate::stream::StreamEvent>>, |
| 346 | stream_mode: crate::stream::StreamMode, |
| 347 | mut context: WorkflowContext, |
| 348 | ) -> GraphBitResult<WorkflowContext> { |
| 349 | self.execute_internal( |
| 350 | workflow, |
| 351 | guardrail_enforcer, |
| 352 | event_tx, |
| 353 | stream_mode, |
| 354 | context, |
| 355 | ) |
| 356 | .await |
| 357 | } |
| 358 | |
| 359 | /// Execute a workflow with real-time streaming events. |
| 360 | /// |
no test coverage detected