D
Membership roles in "Organization Name": Contact account super admin to change your permissions.
Token Permissions:
V
M
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()neverthrow
E
V
options.globalFailureHandler
YI
M
SI
DI
Error: Not implemented yet
B
A
Denv.MY_WORKFLOW.create()
PV
L
L
RV
VL
C
wrangler logout && wrangler login
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
Rconst 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
},
);Erroredinternal error; reference = qkhe7o6ej7li8rrie5v0eks4import { 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();
});