`this.env` - ensuring you pass your `Env` type as a parameter to your Workflow class: https://develo

M

Matt SilverlockOP•4/10/25, 10:04 PM

Example usage: https://developers.cloudflare.com/workflows/examples/backup-d1/

Cloudflare Docs

Export and save D1 database · Cloudflare Workflows docs

Send invoice when shopping cart is checked out and paid for

MMatt Silverlock `this.env` - ensuring you pass your `Env` type as a parameter to your Workflow c...

S

s̸̘̩̓̍ẻ̸͕ͅå̶̡͖ṅ̴̹̊͜•4/10/25, 10:05 PM

good to know, thanks! don't think i saw this documented explicitly btw

Ss̸̘̩̓̍ẻ̸͕ͅå̶̡͖ṅ̴̹̊͜good to know, thanks! don't think i saw this documented explicitly btw

M

Matt SilverlockOP•4/10/25, 10:05 PM

Let me fix!

MMatt Silverlock Thanks - taking a look!

F

felixnorden•4/10/25, 10:47 PM

Do you happen to know how to get passed this issue with running tests with the Vitest Pool Workers library with Workflows that are bound to a Worker and DO? Adding it in causes a similar error to what fredviken is getting. Do I need to do any extra imports in the

vitest.config

vitest.config

vitest.config

vitest.config file as I have the workflow in a separate folder? The durable object class gets resolved without issue, but not the workflow.

Snippet of my wrangler.jsonc below

{
  // Other info
  // ...
  "compatibility_date": "2025-03-17",
  "compatibility_flags": ["nodejs_compat"],

  "observability": {
    "enabled": true
  },

  "durable_objects": {
    "bindings": [
      {
        "name": "TASKS",
        "class_name": "Task"
      }
    ]
  },

  "migrations": [
    {
      "new_sqlite_classes": ["Task"],
      "tag": "v1"
    }
  ],

  "workflows": [
    {
      "binding": "TASK_WORKFLOW",
      "class_name": "TaskWorkflow",
      "name": "task-workflow"
    }
  ],
// Some other bindings with Queues, Services and Rules
// ...
}

{
  // Other info
  // ...
  "compatibility_date": "2025-03-17",
  "compatibility_flags": ["nodejs_compat"],

  "observability": {
    "enabled": true
  },

  "durable_objects": {
    "bindings": [
      {
        "name": "TASKS",
        "class_name": "Task"
      }
    ]
  },

  "migrations": [
    {
      "new_sqlite_classes": ["Task"],
      "tag": "v1"
    }
  ],

  "workflows": [
    {
      "binding": "TASK_WORKFLOW",
      "class_name": "TaskWorkflow",
      "name": "task-workflow"
    }
  ],
// Some other bindings with Queues, Services and Rules
// ...
}

{
  // Other info
  // ...
  "compatibility_date": "2025-03-17",
  "compatibility_flags": ["nodejs_compat"],

  "observability": {
    "enabled": true
  },

  "durable_objects": {
    "bindings": [
      {
        "name": "TASKS",
        "class_name": "Task"
      }
    ]
  },

  "migrations": [
    {
      "new_sqlite_classes": ["Task"],
      "tag": "v1"
    }
  ],

  "workflows": [
    {
      "binding": "TASK_WORKFLOW",
      "class_name": "TaskWorkflow",
      "name": "task-workflow"
    }
  ],
// Some other bindings with Queues, Services and Rules
// ...
}

{
  // Other info
  // ...
  "compatibility_date": "2025-03-17",
  "compatibility_flags": ["nodejs_compat"],

  "observability": {
    "enabled": true
  },

  "durable_objects": {
    "bindings": [
      {
        "name": "TASKS",
        "class_name": "Task"
      }
    ]
  },

  "migrations": [
    {
      "new_sqlite_classes": ["Task"],
      "tag": "v1"
    }
  ],

  "workflows": [
    {
      "binding": "TASK_WORKFLOW",
      "class_name": "TaskWorkflow",
      "name": "task-workflow"
    }
  ],
// Some other bindings with Queues, Services and Rules
// ...
}

S

s̸̘̩̓̍ẻ̸͕ͅå̶̡͖ṅ̴̹̊͜•4/10/25, 11:38 PM

Are there guarantees that in flight workflow requests are allowed to finish when a new worker version is deployed?

We're ready to migrate off Durable Objects in favor of Workflows because DOs don't have this guarantee; just wanted to make sure that Workflows actually do have this property

D

ddsgadget•4/11/25, 2:02 AM

waitForEvent seems really powerful, but I can't figure out how it works exactly. To trigger the event, you need to know its instanceId, await env.MY_WORKFLOW.get(instanceId)m , but how will the external service know the instanceId that is determined by the workflow internally? Your example with Stripe here: https://developers.cloudflare.com/workflows/build/events-and-parameters/#send-events-to-running-workflows is interesting, but how would Stripe know what the instance id is to trigger?

Cloudflare Docs

Events and parameters · Cloudflare Workflows docs

When a Workflow is triggered, it can receive an optional event. This event can include data that your Workflow can act on, including request details, user data fetched from your database (such as D1 or KV) or from a webhook, or messages from a Queue consumer.

S

s̸̘̩̓̍ẻ̸͕ͅå̶̡͖ṅ̴̹̊͜•4/11/25, 3:50 AM

Can multiple workers bind to workflows sharing the same name? For preview deploys, we currently spin up a new worker, but it shares a wrangler.toml as our production deploy, so we would have multiple workers with workflows of the same name.

This UI seems to imply that a given workflow can only have a single bound worker?

EDIT: seems like it can't. templating in our wrangler.toml seems to fix the issue...

I

inaridiy•4/11/25, 5:49 AM

Are there any plans to lift or increase the current limit of 1,000 external requests per workflow instance? Right now, I'm having to split my workflows just to work around this restriction.

S

s̸̘̩̓̍ẻ̸͕ͅå̶̡͖ṅ̴̹̊͜•4/11/25, 6:22 AM

Bug report: workflows are not created in cloudflare when using gradual deploys, at least when created for the first time

Dddsgadget waitForEvent seems really powerful, but I can't figure out how it works exactly....

M

Matt SilverlockOP•4/11/25, 6:24 AM

In most cases you likely want a Worker to do the routing from webhook -> the correct instance, but if (for example) you can attach metadata to the Stripe payment event or subscription request, you can include the instance ID.

Iinaridiy Are there any plans to lift or increase the current limit of 1,000 external requ...

M

Matt SilverlockOP•4/11/25, 6:25 AM

Yes, but will take a bit of time (weeks, not days).

A

Avi•4/11/25, 7:53 AM

now that workflows are GA/production ready, how can i delete a workflow?

AAvi now that workflows are GA/production ready, how can i delete a workflow?

D

Diogo Ferreira•4/11/25, 8:25 AM

Coming very soon

Ffredviken These are the wrangler configs. the workflow is just a simple placeholder one fo...

M

Matt SilverlockOP•4/11/25, 10:13 AM

What version of

wrangler

wrangler

are you using? Make sure it’s the latest (4.8.0 or later).

B

ByteBeast•4/11/25, 10:20 AM

Is there any sample to create workflow using api, as I am trying to make dynamic workflow where user can select how workflow will processed so does anyone have code sample or CURL or anything which can help me out?

MMatt Silverlock In most cases you likely want a Worker to do the routing from webhook -> the cor...

D

ddsgadget•4/11/25, 10:24 AM

Yeah, but the Stripe webhook that trigger the waitForEvent for a particular workflow instance will by definition fire after the workflow has already started. There is no way to put the instance id into Stripe metadata, because there is no way Stripe will have this information. You can't update stripe metadata before something you don't know will happen will happen. This is the case for nearly every single instance where you would use waitFor. The thing that will trigger the waitFor will fire AFTER the workflow starts or what are you waiting for? So there is no way the external event will ever know what the instance is. Reallly the only way I can see that this can possibly work is that both the Workflow and external event that will eventually trigger the waitForEvent both use a predetermined uniqueID that is considered unique across all workflows. In that way the Workflow instance Id would be created with that uniqueId. But this is quite challenging to get right. In the case of orders, I guess you will have a unique order ID that can possibly be shared by Stripe and the Workflow, but this would have to be created by a 3rd party system, so that Stripe and the Worfklow can both know it.

Dddsgadget Yeah, but the Stripe webhook that trigger the waitForEvent for a particular work...

M

Matt SilverlockOP•4/11/25, 10:33 AM

You can set your own instance IDs - you don’t have to create the instance first. For example, the Workflow ID can be the order ID so you have a 1:1 association with those. Or your customer ID, transaction ID, or any other stable identifier that you would otherwise use. Workflows is not unique here.
and/or the Workflow itself can trigger the order, set the webhook, and then wait for the event

M

Matt SilverlockOP•4/11/25, 10:33 AM

I don’t think anything about this example code is impossible to achieve here.

BByteBeast Is there any sample to create workflow using api, as I am trying to make dynamic...

M

Matt SilverlockOP•4/11/25, 10:34 AM

https://developers.cloudflare.com/workflows/build/trigger-workflows/

take a look here

Cloudflare Docs

Trigger Workflows · Cloudflare Workflows docs

You can trigger Workflows both programmatically and via the Workflows APIs, including:

B

ByteBeast•4/11/25, 10:46 AM

No, I am not talking about trigger workflow, I want to create workflow script dynamically using script API.

like below I have make CURL for creating workflow script but getting error

curl --location --request PUT 'https://api.cloudflare.com/client/v4/accounts/$ACCOUNT_ID/workers/scripts/$SCRIPT_NAME' \
--header 'Authorization: Bearer YOUR_API_KEY' \
--header 'Cookie: __cf_bm=BSfapaLrMo7TSHNizMMBSDc1VeGd1iZ6NaF3xErfwlM-1744368032-1.0.1.1-nBYMctsOJZrcH3agouhImrXCYRzeXROKf6uvM4XyDAogoTECkKmo4Fm7q0Vd.XqD6wF1q8urMUiYbpy68QKLd_Opw9i2Y01dtzBoyALEr8Y; __cflb=0H28vgHxwvgAQtjUGUFqYFDiSDreGJnUm6uGcveaJY5; _cfuvid=O4jwRzC_mJfhR25Kh5F.1IIpmpts7JbjH_QwbrurGgk-1744345016081-0.0.1.1-604800000' \
--form 'metadata="{ \"compatibility_date\": \"2021-01-01\", \"compatibility_flags\": [ \"nodejs_compat\" ], \"main_module\": \"worker.ts\" } "' \
--form 'script="export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
  async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
    // Steps here
    let someComputedState = step.do(\"my step\", async () => { })

    // Optional: return state from our run() method
    return someComputedState
  }
};"'

curl --location --request PUT 'https://api.cloudflare.com/client/v4/accounts/$ACCOUNT_ID/workers/scripts/$SCRIPT_NAME' \
--header 'Authorization: Bearer YOUR_API_KEY' \
--header 'Cookie: __cf_bm=BSfapaLrMo7TSHNizMMBSDc1VeGd1iZ6NaF3xErfwlM-1744368032-1.0.1.1-nBYMctsOJZrcH3agouhImrXCYRzeXROKf6uvM4XyDAogoTECkKmo4Fm7q0Vd.XqD6wF1q8urMUiYbpy68QKLd_Opw9i2Y01dtzBoyALEr8Y; __cflb=0H28vgHxwvgAQtjUGUFqYFDiSDreGJnUm6uGcveaJY5; _cfuvid=O4jwRzC_mJfhR25Kh5F.1IIpmpts7JbjH_QwbrurGgk-1744345016081-0.0.1.1-604800000' \
--form 'metadata="{ \"compatibility_date\": \"2021-01-01\", \"compatibility_flags\": [ \"nodejs_compat\" ], \"main_module\": \"worker.ts\" } "' \
--form 'script="export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
  async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
    // Steps here
    let someComputedState = step.do(\"my step\", async () => { })

    // Optional: return state from our run() method
    return someComputedState
  }
};"'

curl --location --request PUT 'https://api.cloudflare.com/client/v4/accounts/$ACCOUNT_ID/workers/scripts/$SCRIPT_NAME' \
--header 'Authorization: Bearer YOUR_API_KEY' \
--header 'Cookie: __cf_bm=BSfapaLrMo7TSHNizMMBSDc1VeGd1iZ6NaF3xErfwlM-1744368032-1.0.1.1-nBYMctsOJZrcH3agouhImrXCYRzeXROKf6uvM4XyDAogoTECkKmo4Fm7q0Vd.XqD6wF1q8urMUiYbpy68QKLd_Opw9i2Y01dtzBoyALEr8Y; __cflb=0H28vgHxwvgAQtjUGUFqYFDiSDreGJnUm6uGcveaJY5; _cfuvid=O4jwRzC_mJfhR25Kh5F.1IIpmpts7JbjH_QwbrurGgk-1744345016081-0.0.1.1-604800000' \
--form 'metadata="{ \"compatibility_date\": \"2021-01-01\", \"compatibility_flags\": [ \"nodejs_compat\" ], \"main_module\": \"worker.ts\" } "' \
--form 'script="export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
  async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
    // Steps here
    let someComputedState = step.do(\"my step\", async () => { })

    // Optional: return state from our run() method
    return someComputedState
  }
};"'

curl --location --request PUT 'https://api.cloudflare.com/client/v4/accounts/$ACCOUNT_ID/workers/scripts/$SCRIPT_NAME' \
--header 'Authorization: Bearer YOUR_API_KEY' \
--header 'Cookie: __cf_bm=BSfapaLrMo7TSHNizMMBSDc1VeGd1iZ6NaF3xErfwlM-1744368032-1.0.1.1-nBYMctsOJZrcH3agouhImrXCYRzeXROKf6uvM4XyDAogoTECkKmo4Fm7q0Vd.XqD6wF1q8urMUiYbpy68QKLd_Opw9i2Y01dtzBoyALEr8Y; __cflb=0H28vgHxwvgAQtjUGUFqYFDiSDreGJnUm6uGcveaJY5; _cfuvid=O4jwRzC_mJfhR25Kh5F.1IIpmpts7JbjH_QwbrurGgk-1744345016081-0.0.1.1-604800000' \
--form 'metadata="{ \"compatibility_date\": \"2021-01-01\", \"compatibility_flags\": [ \"nodejs_compat\" ], \"main_module\": \"worker.ts\" } "' \
--form 'script="export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
  async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
    // Steps here
    let someComputedState = step.do(\"my step\", async () => { })

    // Optional: return state from our run() method
    return someComputedState
  }
};"'

BByteBeast No, I am not talking about trigger workflow, I want to create workflow script dy...

M

Matt SilverlockOP•4/11/25, 10:48 AM

https://developers.cloudflare.com/workers/configuration/multipart-upload-metadata/

see here. You are also missing the Workflow definition. Otherwise, this isn’t specific to Workflows

Cloudflare Docs

Multipart upload metadata · Cloudflare Workers docs

If you're using the Workers Script Upload API or Version Upload API directly, multipart/form-data uploads require you to specify a metadata part. This metadata defines the Worker's configuration in JSON format, analogue to the wrangler.toml file.

Ffelixnorden Do you happen to know how to get passed this issue with running tests with the V...

F

felixnorden•4/11/25, 10:51 AM

Following up on this, have updated Wrangler to the latest version (

4.10

4.10

) but still getting the same errors for running my tests when introducing the workflow

Ffelixnorden Following up on this, have updated Wrangler to the latest version (`4.10`) but s...

S

Seekerdasbatatas•4/11/25, 10:54 AM

in this case, I think that you need to update the

vitest-pool-workers

vitest-pool-workers

package

SSeekerdasbatatas in this case, I think that you need to update the `vitest-pool-workers` package

F

felixnorden•4/11/25, 10:59 AM

Savior, that helped. This thing has been moving forward fast!

MMatt Silverlock https://developers.cloudflare.com/workers/configuration/multipart-upload-metadat...

B

ByteBeast•4/11/25, 11:03 AM

Okay. thanks @Matt Silverlock

MMatt Silverlock 1. You can set your own instance IDs - you don’t have to create the instance fir...

D

ddsgadget•4/11/25, 11:11 AM

"You can set your own instance ID" - OK that is not clear from the docs and examples. I think all the examples I have seen use crypto to create a unique instance. Also, I like the idea of the workflow triggering the actual order. Didn't think of that. Thanks!

Dddsgadget "You can set your own instance ID" - OK that is not clear from the docs and exam...

F

felixnorden•4/11/25, 11:13 AM

What we tend to do is use a shared UUID for various items and prefix with what the consumer is, e.g.,

workflow-${uuid}

workflow-${uuid}

so you can debug more easily too if/when things go south

Dddsgadget "You can set your own instance ID" - OK that is not clear from the docs and exam...

M

Matt SilverlockOP•4/11/25, 11:14 AM

Where can we make this clearer? Documented here: https://developers.cloudflare.com/workflows/build/workers-api/#create

An ID is automatically generated, but a user-provided ID can be specified (up to 64 characters 1). This can be useful when mapping Workflows to users, merchants or other identifiers in your system.

We kept the tutorial simpler (because otherwise we get feedback that we’re introducing too much!)

Ffelixnorden What we tend to do is use a shared UUID for various items and prefix with what t...

M

Matt SilverlockOP•4/11/25, 11:15 AM

100% this. Same as you would with Temporal or other async workflow systems.

MMatt Silverlock Where can we make this clearer? Documented here: https://developers.cloudflare.c...

D

ddsgadget•4/11/25, 11:18 AM

Yeah, I see it there now. I'm not sure how you can make this clearer. It's easy to miss that. And also, I generally read examples first and learn from that, and don't go back to the docs unless I need something new or have a bug. And all the examples either don't create the instance and let it be done automatically or they use crypto. So that's how I've been doing it. Maybe have an example with an instance ID that is user-provided? Not really sure.

Dddsgadget Yeah, I see it there now. I'm not sure how you can make this clearer. It's easy ...

M

Matt SilverlockOP•4/11/25, 11:21 AM

Yeah - maybe we can link out from the guide so it’s mentioned but doesn’t pollute the tutorial / add too much up front

M

Matt SilverlockOP•4/11/25, 11:21 AM

Or a code comment (or both)

MMatt Silverlock What version of `wrangler` are you using? Make sure it’s the latest (4.8.0 or la...

F

fredviken•4/11/25, 11:23 AM

Both the workers were using 4.9.1. I just tried updating to the latest (4.10.0) but I still get the same error message

F

felixnorden•4/11/25, 3:24 PM

Is there a way to use the chrome debugger inside the workflow steps? I'm unable to hook into it from the main pool, but the worker and DOs work there. Trying to figure out why I'm not getting error logs in a dedicated class that's being called in the step.

WWallslide I was thinking workflows would be a great usecase for handling IOT messages, but...

B

boop•4/11/25, 5:52 PM

The way I'm getting around the limit is popping messages into a queue and then batching 100 messages or every 10 seconds to a workflow. When hitting the ratelimit, the queue will redeliver in the next batch

B

boop•4/11/25, 5:54 PM

Although my usecase isn't time sensitive, it's handling user registrations

MMatt Silverlock One request per Workflow. You can retry any that fail (although that should be v...

H

hugo martins•4/11/25, 6:52 PM

We can retry them, of course — but workflows are meant to be about durable execution. What I was expecting was a way to trigger multiple distinct workflows transactionally with a single request. That way, if the Cloudflare Workflows API goes down or we hit a quota/limit issue, either all workflows start or none do — instead of ending up in a half-started, inconsistent state.

By having to manage retries ourselves, we’re essentially recreating the very problem that workflows are supposed to solve, aren’t we?

Hhugo martins We can retry them, of course — but workflows are meant to be about durable execu...

M

Matt SilverlockOP•4/11/25, 6:58 PM

How are you solving this today/elsewhere? What requires these Workflows to be tightly coupled in a way that can’t be solved by using one Workflow vs trying to spread across many?

(To be clear, this doesn’t mean we wouldn’t consider a transactional API, but it’s non-trivial across multiple unrelated Workflows, because that has a performance + complexity cost)

J

jasperagrante•4/12/25, 3:59 PM

What's the best way to use Queues to limit the concurrency of Workflows? Or would it be just polling the workflow status and using setTimeout to sleep on the consumer before ack'ing the message?

WWallslide what if you had workflow steps dumping their work into queues

J

jasperagrante•4/12/25, 5:00 PM

Ohh yeah, that might work! I've just discovered

waitForEvent

waitForEvent

earlier. I might be able to queue from the workflow and use send event to resume the flow. Thanks!

I

Isak•4/14/25, 4:02 PM

Is this released or coming in the future? "When creating a Workflow instance, you can set a shorter state retention period if you do not need to retain state for errored or completed Workflows."

IIsak Is this released or coming in the future? "When creating a Workflow instance, yo...

M

Matt SilverlockOP•4/14/25, 7:21 PM

Coming soon.

A

aza547•4/14/25, 9:43 PM

Hello, is there a subrequest limit on workflows? Trying to work out if it fits my use case which I expect to need to make several thousand subrequests to R2. I was looking at a scheduled worker job but I think that certainly does have a 1000 subrequest limit. The docs seem a little unclear in that there is no explicit limit here but it states "Many limits are inherited... [from Workers]".

Cloudflare Docs

Limits · Cloudflare Workflows docs

Limits that apply to authoring, deploying, and running Workflows are detailed below.

D

D Trombett•4/14/25, 10:09 PM

Yep, the limit is the same as workers

A

aza547•4/14/25, 10:10 PM

Thanks!

S

s̸̘̩̓̍ẻ̸͕ͅå̶̡͖ṅ̴̹̊͜•4/14/25, 10:11 PM

How can we disable retries? Is is sufficient to set

retries

retries

to

?

We did this and still are still seeing retries in our dashboard.

`this.env` - ensuring you pass your `Env` type as a parameter to your Workflow class: https://develo

Similar Threads

Similar Threads

Similar Threads