Function: dag()

function dag(
   nodes,
   connection,
   prefix?
): Promise<ClosableWorkflow<Map&lt;string, Job&lt;any, any>>>>;

Defined in: glide-mq/src/workflows.ts:175

DAG: submit a directed acyclic graph of jobs where each job can depend on multiple other jobs. The graph is validated for cycles and submitted in topological order (leaves first).

Returns a Map of node name to Job instance. Pass { client } on the connection to keep returned jobs usable.

Parameters

Parameter	Type
nodes	DAGNode[]
connection	WorkflowConnection
prefix?	string

Returns

Promise<ClosableWorkflow<Map<string, Job<any, any>>>>