N
, If I have a workflow in progress (for example, currently at step 2 of 3), and I deploy a new version of the workflow that removes or changes step 3, what happens to the in-progress workflow?
DD
N
H
sorry for the ping, but would really love to know your thoughts on this. It would be great to have the ability to handle fatal errors at the workflow level, rather than having to handle each step individually.H
step.do.catch() on it!neverthrow in your project like I am, you can do this! TT
E
V
options.globalFailureHandlerV
Y
I
M
SI
DI
Error: Not implemented yet
B
A
Denv.MY_WORKFLOW.create() call? If so, let's say after user registration, we want to setup billings, welcome emails, etc for the user (our most common use-case currently), with our usual load, we would that limit incredibly quickly, what is the solution for these scenarios?
PV
L
L
RV
VL
C
wrangler logout && wrangler login a few times but its flaky and odd
TTCTT
Step map csv to contacts-1 output is too large. Maximum allowed size is 1MiB.
J
J
Jwrangler dev
M
MM
MJJ
Errored status.wrangler dev
A
RJ
internal error; reference = 4t7lk8kksul8hag46prmnndtJ
M
.catch()neverthrowoptions.globalFailureHandlerError: Aborting engine: Grace period completeError: Not implemented yetenv.MY_WORKFLOW.create()A request to the Cloudflare API (/accounts/<id>/workflows/<name>) failed.
Authentication error [code: 10000]wrangler logout && wrangler loginStep map csv to contacts-1 output is too large. Maximum allowed size is 1MiB.Erroredinternal error; reference = qkhe7o6ej7li8rrie5v0eks4internal error; reference = 4t7lk8kksul8hag46prmnndtconst validationResult = await step
.do('validate', async () => {
// do some logic here
return { somedata: true };
})
.catch((e) => {
// handle your error here, and possibly re-throw it if you want it to be fatal
});const validationResult = await fromPromise(
step.do('validate', async () => {
// do some logic that could throw here
return { somedata: true };
}),
(e) => e,
).match(
(result) => result,
(e) => {
// handle your error here, and possibly re-throw it if you want it to be fatal
},
);import { WorkflowEntrypoint, WorkflowStep, WorkflowEvent, DurableObject } from 'cloudflare:workers';
import { ActionEvent } from '../types/events';
export class Portal extends DurableObject<Env> {
constructor(ctx: DurableObjectState, env: Env) {
super(ctx, env);
console.log('Initialising portal Durable Object');
}
async test(): string {
return "Hello!";
}
}
export class ActionWorkflow extends WorkflowEntrypoint<Env, ActionEvent> {
async run(params: WorkflowEvent<ActionEvent>, step: WorkflowStep) {
const event = params.payload;
const portalIdString = event.portal_id.toString();
console.log('Starting workflow', event);
const portal = this.env.PORTAL.getByName(portalIdString);
const test = await portal.test();
await step.do('test', async () => {
console.log(test);
});
}
}const portalResponse = await step.do('get-portal-response', async () => {
const portal = this.env.PORTAL.getByName(portalIdString);
return await portal.test();
});