Function: chord()

function chord(
   queueName,
   groupJobs,
   callback,
   connection,
   prefix?
): Promise<ClosableWorkflow<JobNode>>;

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

Chord: run a group of jobs in parallel, then execute a callback job with the results. The callback is the parent, the group members are children.

Returns the JobNode tree. The root is the callback job. Pass { client } on the connection to keep returned jobs usable.

Parameters

Parameter	Type
queueName	string
groupJobs	WorkflowJobDef[]
callback	WorkflowJobDef
connection	WorkflowConnection
prefix?	string

Returns

Promise<ClosableWorkflow<JobNode>>