My 'waitForEvent' gets notified before my workflow is listening for the event?

[dejoma]

// In the Workflow logs we can see that this is e.g. 3:08:06PM
const eventId = await context.run<string | null>(
      'pdf-export.started',
      async () => {
        const eventId = crypto.randomUUID();
        await invokeLambda('pdfExportContainer', {
          course,
          imageUrl,
          ...lambdaPayload,
          eventId
        });
        return eventId;
      }
    );

  // This part is not relevant
  if (!eventId) {
    await context.run<void>('error.pdf-export.failed', async () => {
      throw new Error('Failed to generate PDF');
    });

    ...
    return;
  }

    // In the Workflow logs we can see that this is e.g. 3:08:08PM meanwhile we notified 
     already one second before that
    const { eventData, timeout } = await context.waitForEvent(
      'pdf-export.completed',
      eventId,
      {
        timeout: '15m'
      }
    );

My issue with the above code is that my lambda function reaches the "notify workflow" function within 5 seconds. And then the context.waitForEvent is not yet called.

What is the average time between these "workflow steps"? Can it be that that takes about 10 seconds?

[CahidArda]

Hi @dejoma,

The time between the steps should be minimal. It shouldn't take 10 seconds. Can you reach out through support so we can check our internal logs?

One thing you can try is to run the context.run and context.waitForEvent steps parallel:

const eventId = await context.run("get event id", () => crypto.randomUUID())

await Promise.all([
  context.run("pdfExportContainer", ...),
  context.waitForEvent("pdf-export.completed", eventId, { timeout: "15m" })
])

In the meantime, we are going to discuss a more ideal solution with the team.

[ahmedriad1]

I'm facing the same issue, @CahidArda . We need a way to do something like this:

const eventId = await context.run("get event id", () => crypto.randomUUID());

// upstash will listen for the event in the background
const event = await context.createEvent(`pdf-export.completed-${eventId}`, { timeout: "15m" }); 

await context.run("pdfExportContainer", ...);

// will stop the workflow until the event is received
await context.waitForEvent(event);