const flow = new FlowProducer({ connection });
const originalTree = await flow.add({
queueName: 'topQueueName',
data: { idx: 0, foo: 'bar' },
queueName: 'childrenQueueName',
data: { idx: 4, foo: 'baz' },
queueName: 'grandchildrenQueueName',
data: { idx: 2, foo: 'foo' },
queueName: 'childrenQueueName',
data: { idx: 3, foo: 'bis' },
queueName: 'childrenQueueName',
const { job: topJob } = originalTree;
const tree = await flow.getFlow({
queueName: 'topQueueName',
const { children, job } = tree;