Are there any other workflows in your account? Note that the concurrency limit is account wide
Are there any other workflows in your account? Note that the concurrency limit is account wide
.restart() is not implemented yet
javascript debug terminal and it works fine. For some reason it doesn't w/ workflows - all of my breakpoints are "unbound"javascript debug terminal I have to run wrangler dev and then attach vs code to the process. The same works fine w/ workflows.instance.restart, instance.terminate, etc. and it says Not implemented yet. Any tips on that?--remote)--remoteconsole.logsexport class myclass extends WorkflowEntrypoint<Env, Params> {
async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
}
}// Can access bindings on this.env
max_concurrent_instances config.step.sleep duration is in seconds if it's a number but it seems to me that it's actually ms?Worker "workflows:AfterContractActivated-development"'s binding "USER_WORKFLOW" refers to a service "core:user:delivery-development", but no such service is defined.onError callback i could pass where i could set some custom logic to try when a step errors. E.g.:onError callback would still have to be treated like another step, but ends up being another not-quite-a-step API with its own semantics.WORKFLOW_SERVICE Env variabe as? export class myclass extends WorkflowEntrypoint<Env, Params> {
async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
}
}Worker "workflows:AfterContractActivated-development"'s binding "USER_WORKFLOW" refers to a service "core:user:delivery-development", but no such service is defined.export class TextGenerator extends WorkflowEntrypoint<CloudflareBindings> {
async run(
event: Readonly<WorkflowEvent<{ prompt: string }>>,
step: WorkflowStep,
) {
const { prompt } = event.payload;
return await step.do(
"generate-text",
{
retries: { limit: 3, delay: 1000, backoff: "exponential" },
onError: async (error, retry) => {
if (error instanceof AITimeoutError) {
// Complex model timed out, try with a faster one first
try {
return await generateText({
model: "gpt-3.5-turbo",
prompt,
timeout: 5000,
});
} catch {
// If faster model fails, retry with original complex model (retry is the original callback in step.do)
return retry();
}
}
throw error;
}
}, "services": [
{
"binding": "WORKFLOW_SERVICE",
"service": "wf-portcity-ai"
}
],