Struct CatalogWorkflowDagBuilder 

pub struct CatalogWorkflowDagBuilder<'a, 'catalog> { /* private fields */ }

Workflow DAG builder that validates job types against a JobCatalog.

Implementations

impl<'a, 'catalog> CatalogWorkflowDagBuilder<'a, 'catalog>

pub fn organization_id(self, organization_id: Uuid) -> Self

Sets the organization scope for the workflow run and its steps by default.

pub fn clear_organization_id(self) -> Self

Clears the workflow-level organization scope.

pub fn idempotency_key(self, idempotency_key: &'a str) -> Self

Sets the workflow idempotency key.

pub fn clear_idempotency_key(self) -> Self

Clears the workflow idempotency key.

pub fn job( self, step_key: &'a str, job_type_name: &str, payload: &'a Value, ) -> Result<Self, CatalogError>

Adds a job step after validating job_type_name against enabled catalog entries.

Errors

Returns CatalogError when the job type is unknown or disabled, or when the underlying workflow builder rejects the step.

pub fn after_success<I>( self, step_key: &'a str, prerequisites: I, ) -> Result<Self, CatalogError>

where I: IntoIterator<Item = &'a str>,

Adds success dependencies to an existing workflow step.

Errors

Returns CatalogError::WorkflowBuild when the underlying workflow builder rejects the dependency edge.

pub fn after_terminal<I>( self, step_key: &'a str, prerequisites: I, ) -> Result<Self, CatalogError>

where I: IntoIterator<Item = &'a str>,

Adds terminal-state dependencies to an existing workflow step.

Errors

Returns CatalogError::WorkflowBuild when the underlying workflow builder rejects the dependency edge.

pub fn build(self) -> Result<WorkflowRunEnqueue<'a>, CatalogError>

Builds the workflow enqueue payload.

This is an alias for Self::try_build.

Errors

Returns CatalogError::WorkflowBuild when final workflow validation fails.

pub fn try_build(self) -> Result<WorkflowRunEnqueue<'a>, CatalogError>

Builds the workflow enqueue payload.

Errors

Returns CatalogError::WorkflowBuild when final workflow validation fails.

Trait Implementations

impl<'a, 'catalog> Clone for CatalogWorkflowDagBuilder<'a, 'catalog>

fn clone(&self) -> CatalogWorkflowDagBuilder<'a, 'catalog>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a, 'catalog> Debug for CatalogWorkflowDagBuilder<'a, 'catalog>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.