import { WorkflowEntrypoint } from 'cloudflare:workers';

export class MyWorkflow extends WorkflowEntrypoint {
    async run(event, step) {

        const one = await step.do('first step', async () => {
            console.info('first step');
            return { foo: 'bar' };
        });

        await step.do('second step', async () => {
            console.info('second step');
        });

        console.info('workflow complete');
    }
}

export default {
    async fetch(req, env) {
        const instance = await env.MY_WORKFLOW.create();
        const status = await instance.status();
        console.info('created workflow:', instance.id, status);
        return Response.json({
            id: instance.id,
            details: status,
        });
    }
}

import { WorkflowEntrypoint } from 'cloudflare:workers';

export class MyWorkflow extends WorkflowEntrypoint {
    async run(event, step) {

        const one = await step.do('first step', async () => {
            console.info('first step');
            return { foo: 'bar' };
        });

        await step.do('second step', async () => {
            console.info('second step');
        });

        console.info('workflow complete');
    }
}

export default {
    async fetch(req, env) {
        const instance = await env.MY_WORKFLOW.create();
        const status = await instance.status();
        console.info('created workflow:', instance.id, status);
        return Response.json({
            id: instance.id,
            details: status,
        });
    }
}