Skip to content

Function: group() ​

ts
function group(
   queueName,
   jobs,
   connection,
   prefix?
): Promise<ClosableWorkflow<JobNode>>;

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

Group: execute jobs in parallel. All jobs run concurrently. A synthetic parent job (name: 'group') waits for all children. When complete, the parent's processor receives all children's results via getChildrenValues().

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

Parameters ​

ParameterType
queueNamestring
jobsWorkflowJobDef[]
connectionWorkflowConnection
prefix?string

Returns ​

Promise<ClosableWorkflow<JobNode>>

Released under the Apache-2.0 License.