export class SimpleWorkflow extends WorkflowEntrypoint<
Env,
SimpleWorkflowPayload
> {
async run(event: WorkflowEvent<SimpleWorkflowPayload>, step: WorkflowStep) {
console.log("Simple workflow started", event.payload);
await step.do("testing timeout", async () => {
console.log(`Initializing test: ${event.payload.name}`);
const eventResponse = await step.waitForEvent("waiting for event", {
type: "test",
timeout: 10000,
});
console.log("Test event received", eventResponse);
return { status: "initialized" };
});
console.log("workflow complete");
}
}
export class SimpleWorkflow extends WorkflowEntrypoint<
Env,
SimpleWorkflowPayload
> {
async run(event: WorkflowEvent<SimpleWorkflowPayload>, step: WorkflowStep) {
console.log("Simple workflow started", event.payload);
await step.do("testing timeout", async () => {
console.log(`Initializing test: ${event.payload.name}`);
const eventResponse = await step.waitForEvent("waiting for event", {
type: "test",
timeout: 10000,
});
console.log("Test event received", eventResponse);
return { status: "initialized" };
});
console.log("workflow complete");
}
}