Include run id in batch trigger example

2023-12-07 13:21:55 +00:00
parent 4cb87c5cff
commit 59a037088b
1 changed files with 2 additions and 1 deletions
@@ -193,12 +193,13 @@ client.defineJob({
      oversized: z.boolean().default(false),
    }),
  }),
-  run: async (payload, io) => {
+  run: async (payload, io, ctx) => {
    for (let i = 0; i < payload.payloads; i++) {
      await io.sendEvent(`send-${i}`, {
        name: "batch.trigger",
        payload: {
          count: i,
+          run: ctx.run.id,
          ...(payload.oversized
            ? {
                largePayload: getLargeString(250 * 1000), // 250KB