Struct WorkflowEvaluator

pub struct WorkflowEvaluator { /* private fields */ }

Represents a WDL V1 workflow evaluator.

This type is cheaply cloned.

Implementations

impl WorkflowEvaluator

pub async fn new(config: Config, token: CancellationToken) -> Result<Self>

Constructs a new workflow evaluator with the given evaluation configuration and cancellation token.

This method creates a default task execution backend.

Returns an error if the configuration isn’t valid.

pub fn new_with_backend( config: Config, backend: Arc<dyn TaskExecutionBackend>, token: CancellationToken, ) -> Result<Self>

Constructs a new workflow evaluator with the given evaluation configuration, task execution backend, and cancellation token.

Returns an error if the configuration isn’t valid.

pub async fn evaluate<P, R>( &self, document: &Document, inputs: WorkflowInputs, root_dir: impl AsRef<Path>, progress: P, ) -> EvaluationResult<Outputs>

where P: Fn(ProgressKind<'_>) -> R + Send + Sync + 'static, R: Future<Output = ()> + Send,

Evaluates the workflow of the given document.

Upon success, returns the outputs of the workflow.

Trait Implementations

impl Clone for WorkflowEvaluator

fn clone(&self) -> WorkflowEvaluator

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.