MCPcopy Create free account
hub / github.com/InfinitiBit/graphbit / execute_with_context

Method execute_with_context

core/src/workflow.rs:341–357  ·  view source on GitHub ↗
(
        &self,
        workflow: Workflow,
        guardrail_enforcer: Option<Arc<Enforcer>>,
        event_tx: Option<tokio::sync::mpsc::Sender<crate::stream::StreamEvent>>,
        stream_mode: cr

Source from the content-addressed store, hash-verified

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 ///

Calls 1

execute_internalMethod · 0.80

Tested by

no test coverage detected