Skip to content

Commit 8f434cb

Browse files
committed
add catalog entry for dependency waits in loops
1 parent 8cc207e commit 8f434cb

File tree

1 file changed

+26
-0
lines changed

1 file changed

+26
-0
lines changed

references/v3-catalog/src/trigger/subtasks.ts

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,3 +139,29 @@ export const multipleTriggerWaits = task({
139139
};
140140
},
141141
});
142+
143+
export const triggerAndWaitLoops = task({
144+
id: "trigger-wait-loops",
145+
run: async ({ message = "test" }: { message?: string }) => {
146+
for (let i = 0; i < 2; i++) {
147+
await simpleChildTask.triggerAndWait({ payload: { message: `${message} - ${i}` } });
148+
}
149+
150+
for (let i = 0; i < 2; i++) {
151+
await simpleChildTask.batchTriggerAndWait({
152+
items: [
153+
{ payload: { message: `${message} - ${i}.a` } },
154+
{ payload: { message: `${message} - ${i}.b` } },
155+
],
156+
// batchOptions: { maxConcurrency: 1 },
157+
});
158+
}
159+
160+
// Don't do this!
161+
// await Promise.all(
162+
// [{ message: `${message} - 1` }, { message: `${message} - 2` }].map((payload) =>
163+
// simpleChildTask.triggerAndWait({ payload })
164+
// )
165+
// );
166+
},
167+
});

0 commit comments

Comments
 (0)