26 replies

Hi folks - having some trouble with

Hi folks - having some trouble with throwing errors inside a workflow.

First, it seems throwing a NonRetryableError, is retried as many times as specified

Second, I can't seem to find out where the throw error messages are being returned in the workflow status. The docs seem to say

const wf = await MY_WORKFLOW.get(id)

const wf = await MY_WORKFLOW.get(id)

and then

await wf.status()

await wf.status()

should return errors, but they are always empty.

here is the code I'm using to reproduce:

export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
    async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
        step.do('Step 1', async () => { return 'Step 1 finished!';  });

        step.do('Step 2', {
            retries: { limit: 2, delay: '1 second', backoff: 'linear', },
        }, async () => {
            console.log('Trying Step 2');
            throw new NonRetryableError('Step 3 failed. Non-retryable');
        });
    }
}

export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
    async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
        step.do('Step 1', async () => { return 'Step 1 finished!';  });

        step.do('Step 2', {
            retries: { limit: 2, delay: '1 second', backoff: 'linear', },
        }, async () => {
            console.log('Trying Step 2');
            throw new NonRetryableError('Step 3 failed. Non-retryable');
        });
    }
}

This logs "trying step 2" three times

Cloudflare Developers•14mo ago•

26 replies

wesbos

Hi folks - having some trouble with

const wf = await MY_WORKFLOW.get(id)

const wf = await MY_WORKFLOW.get(id)

and then

await wf.status()

await wf.status()

should return errors, but they are always empty.

here is the code I'm using to reproduce:

export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
    async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
        step.do('Step 1', async () => { return 'Step 1 finished!';  });

        step.do('Step 2', {
            retries: { limit: 2, delay: '1 second', backoff: 'linear', },
        }, async () => {
            console.log('Trying Step 2');
            throw new NonRetryableError('Step 3 failed. Non-retryable');
        });
    }
}

export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
    async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
        step.do('Step 1', async () => { return 'Step 1 finished!';  });

        step.do('Step 2', {
            retries: { limit: 2, delay: '1 second', backoff: 'linear', },
        }, async () => {
            console.log('Trying Step 2');
            throw new NonRetryableError('Step 3 failed. Non-retryable');
        });
    }
}

This logs "trying step 2" three times

Hi folks - having some trouble with

Similar Threads

Hi folks - having some trouble with

Similar Threads

Similar Threads

Similar Threads