Cloudflare Developers

CD

Cloudflare Developers

Welcome to the official Cloudflare Developers server. Here you can ask for help and stay updated with the latest news

Join

workflow create batch issues

hi, I sent a batch of 5,000 workflow executions, and for some reason, many of them are stuck in a "QUEUED" state. No failures, no errors --just hanging there in that state...

Creating a workflow that is iterating

Creating a workflow that is iterating through a list with pagination. The pagination operation works with a next_cursor so that you know the next page to go and fetch. My question: Can I capture the next_cursor in a let like below to reference in each subsequent step? ```ts let next_cursor;...

Right, we should have expected retry

Right, we should have expected retry functionality there correct? It appears that it was in that stuck in that Running state. When I queried for the events for this instanceId via the GraphQL analytics API - there was only 1 ATTEMPT_START for that ID, I do not see that any retries were executed. Even after I terminated the instance, while the workflow run changed the status to Terminated, the step status still says Running. See screenshot. Perhaps I've misconfigured something? Thank you for your help!...
No description

If I try and use cross-script calls like

If I try and use cross-script calls like in the documentation... WORKER A wrangler.toml ``` [[workflows]]...

I have workflow working locally and I

I have workflow working locally and I see the binding working on remote, but when I try to trigger it via worker I am seeing TypeError: Cannot read properties of undefined (reading 'create') c.env.COVE_WORKFLOW_VIDEO.create({ I think it is saying that the actual workflow is not bound. below is the hono api call that triggers it...

It might be naive question but i am

It might be naive question but i am having hard time seeing console output. i have a workflow that makes call to AWS lambda and for some reasons lambda is returning error, to debug, i have added logs, which do not appear in workflow dashboard, and i see nothing in wrangler tail. is there any guide or recommendation on how to debug the workflow?

Hey, i'm noticing a lot of errors with

Hey, i'm noticing a lot of errors with the messages thrown by step.do. and workflows not loading on cloudflare since yesterday, this wasn't happening before A call to blockConcurrencyWhile() in a Durable Object waited for too long. The call was canceled and the Durable Object was reset is it just me or is anyone else having the same issue? 🤔...

Seeing this error:

Seeing this error: ``` { "$workers": {...

Hi all, just started using workflows.

Hi all, just started using workflows. Overall, extremely rad. Something baffling me is the __LOCAL_DEV_STEP_OUTPUTS and what the equivalent would be from a deployed workflow? obvs I can trial-and-error this, but I wanted to ID documentation on this vs. "production" outputs 😄...

Gotcha - ok, thank you! I'll do some

Gotcha - ok, thank you! I'll do some experimentation later today to see if I can get it to work with another worker w/ service bindings - and if not, probably another worker doing a normal fetch().

can someone confirms AsyncLocalStorage

can someone confirms AsyncLocalStorage will not behave as expected in a step fn unless the callback is defined inline ? ```ts async run(event: WorkflowEvent<Params>, step: WorkflowStep) { await context.run({ id: "124" }, async () => { // loadFile will get undefined when calling content.getStore() ...

Hey!

Hey! I'm trying to use Workflows within an existing Workers project. The project is using vite to build a remix app. But I'm getting this error if I try to add a workflows configuration into wrangler.jsonc: ```Worker "workflows:workflow"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "ExcelImportWorkflow", but "core:user:" has no such named entrypoint....

Workers RPC — Lifecycle · Cloudflare Wor...

Hi all! I'm running into the following error when using Workflows: An RPC stub was not disposed properly. You must call dispose() on all stubs in order to let the other side know that you are no longer using them. You cannot rely on the garbage collector for this because it may take arbitrarily long before actually collecting unreachable objects. As a shortcut, calling dispose() on the result of an RPC call disposes all stubs within it. I see that step.do expects to return Rpc.Serializable<unknown>, so I did a little bit of reading about the RPC lifecycle here and found that in the context of Worker Service Bindings, you should either use the experimental using syntax, or explicitly call object[Symbol.dispose](). ...

Hi folks - having some trouble with

Hi folks - having some trouble with throwing errors inside a workflow. First, it seems throwing a NonRetryableError, is retried as many times as specified Second, I can't seem to find out where the throw error messages are being returned in the workflow status. The docs seem to say const wf = await MY_WORKFLOW.get(id) and then await wf.status() should return errors, but they are always empty....

is `npx wrangler types` supposed to work

is npx wrangler types supposed to work for workflows? wrangler.toml: services = [{ binding = "WORKFLOW_PROCESS_TRANSACTIONS", service = "money" }] wrangler version: wrangler 3.107.3 generated interface, WORKFLOW_PROCESS_TRANSACTIONS should be Workflow? ```...

Workflow limits

Ok thanks, well this is somewhat concerning if there are some tasks which use memory too much. That's why may be my workflow steps are throwing an error of cpu/memory limit after doing work of around 128 MiB ( nearly ) But on retry it's again working till 128 MiB ...

Hi all. Is it possible to pause/resume

Hi all. Is it possible to pause/resume workflow steps and wait for user input? We're using workflows for order processing. For new users, we require that the user verifies their identity with an external KYC provider. Is there a way to wrap this in a step that will block until the user has verified their identity? Some kind of signal mechanism similar to what Temporal has? Thanks in advance....

Error handling seems quite complex. I

Error handling seems quite complex. I have a tail worker that should post to the bug tracking app, but it doesn't seem to catch exceptions at all tail worker excerpt: ``` async tail(events, env, ctx) {...

I'm getting this error with the

I'm getting this error with the cloudflare blank starter repo when I change the index.ts to use workflows (the test passed before0 ``` [vpw:inf] Starting isolated runtimes for vitest.config.mts... Worker "workflows:telegram-mod-wf"'s binding "USER_WORKFLOW" refers to service "core:user:vitest-pool-workers-runner-" with a named entrypoint "MessageHandler", but "core:user:vitest-pool-workers-runner-" has no such named entrypoint....
Next