I can't seem to figure out, how do I limit the amount of instances per minute a workflow can ingest?

B

bkyerv•10/31/24, 9:21 AM

an attempt to delete a workflow from the cli results in an error saying it failed. in the dashboard I have already deleted connected worker but the workflow itself doesn't get deleted regardless of how many times I try to delete it by way of

wrangler workflows delete workflows-starter

wrangler workflows delete workflows-starter

wrangler workflows delete workflows-starter

wrangler workflows delete workflows-starter

Bbkyerv an attempt to delete a workflow from the cli results in an error saying it faile...

F

fry69•10/31/24, 9:26 AM

Deleting Workflows is still not possible as far as I know -> workflows

B

bkyerv•10/31/24, 9:28 AM

why then do they keep this in their docs. thank you for pionting it out though

Bbkyerv why then do they keep this in their docs. thank you for pionting it out though

F

fry69•10/31/24, 9:30 AM

Nobody told the docu team I guess

Ffry69 Nobody told the docu team I guess 🙂

A

AdvanyOP•10/31/24, 9:53 AM

its a beta... just opened up... lets be kind that they didn't wait till everything was polished

AAdvany its a beta... just opened up... lets be kind that they didn't wait till everythi...

F

fry69•10/31/24, 9:55 AM

Of course, but it's been a few days since it is officially known, they could have added a note that this is currently not supported IMHO, esp. since this is so prominently mentioned in the docs

Ffry69 Of course, but it's been a few days since it is officially known, they could hav...

A

AdvanyOP•10/31/24, 10:17 AM

yeah, there are also a couple of other things. I think it will get fixed soon (like the create locally needing an id)

B

bkyerv•10/31/24, 11:49 AM

is it possible to access env vars from inside workflows? e.g. to access db usually a token/url is needed that is saved in the env

Bbkyerv is it possible to access env vars from inside workflows? e.g. to access db usual...

I

itsmatteomanf•10/31/24, 11:51 AM

Access is the same as a normal worker, but it requires a

this.

this.

this.

this. before accessing it… it’s not mentioned in the docs, they will add it

B

bkyerv•10/31/24, 11:53 AM

I see, thank you!

B

bkyerv•10/31/24, 11:55 AM

in general are there any materials that show cases of proven practices that work well with workflows? i.e. is it better to keep interaction with the db inside the workflow or outside of the workflow in the worker itself. or more generally what actions are better to perform inside workflow vs. inside a regular worker?

AAdvany I can't seem to figure out, how do I limit the amount of instances per minute a ...

A

AdvanyOP•10/31/24, 12:02 PM

I made a workaround. Add the workflow items to a d1. Then a do sends it every 10 seconds to the workflow. Dripping it into it.

Would be great if we could just add that on step level of workflow level

AAdvany I made a workaround. Add the workflow items to a d1. Then a do sends it every 10...

A

AdvanyOP•10/31/24, 12:05 PM

Just though about it now. I could have created a workflow that goes thru the list and sleeps between each entry...

Bbkyerv in general are there any materials that show cases of proven practices that work...

I

itsmatteomanf•10/31/24, 12:24 PM

The less work each step makes, the better. Each step will be retried, persisting results from other steps, but not variables outside of those (so the variable assigned from a step return is maintained, a random variable is not)

I

itsmatteomanf•10/31/24, 12:24 PM

Do a db step, do a processing step (or even a per item processing, if it’s a loop and it’s not too long to go over the step limit)

I

itsmatteomanf•10/31/24, 12:25 PM

Do consider that you can nest steps, too. If you were to need that.

B

bkyerv•10/31/24, 12:36 PM

thank you

Iitsmatteomanf Do a db step, do a processing step (or even a per item processing, if it’s a loo...

D

DiamondDragon•10/31/24, 2:35 PM

Isn’t the step limit 250? So I have a step that return an object of 500 items and need to loop over each item to make another external api call and do further processing, I can’t have a nested step inside the for loop to process each item? Since it sounds like I’d hit the step limit

DDiamondDragon Isn’t the step limit 250? So I have a step that return an object of 500 items an...

I

itsmatteomanf•10/31/24, 2:56 PM

Exactly, yes. The limit is 255 steps.

I

itsmatteomanf•10/31/24, 2:56 PM

Do remember that you still have the 1k subrequest limit that applies and that retries will be counted against this limit.

D

DanGamble•10/31/24, 2:59 PM

Has multiple workflows with local wrangler been "fixed" yet? I can't see any issues in the

wrangler-sdk

wrangler-sdk

wrangler-sdk

wrangler-sdk repo. Shall I create one if it's not been fixed? Not sure where the state of this bug would be kept

DDanGamble Has multiple workflows with local wrangler been "fixed" yet? I can't see any iss...

D

DiamondDragon•10/31/24, 3:13 PM

still broken as of last night since i ran into it

Iitsmatteomanf Exactly, yes. The limit is 255 steps.

D

DiamondDragon•10/31/24, 3:14 PM

Hmm maybe i'll process 10 at a time then

M

movaid7•10/31/24, 3:54 PM

I haven't seen this mentioned anywhere in the docs - I can't figure out if sleeping executions are counted towards the concurrency limit.
general-helpDo sleeping Workflows count towards the maximum concurrent execution limit?

S

saba•10/31/24, 8:13 PM

Is there a way to have a monorepo of several workflows in one repository ?

S

saba•10/31/24, 8:34 PM

is someone succeded with same setup as for workers?

Ssaba Is there a way to have a monorepo of several workflows in one repository ?

M

Matt Silverlock•11/1/24, 1:43 PM

Yes, but right now that is broken in local dev. Search this channel for “multiple Workflows”

MMatt Silverlock Yes, but right now that is broken in local dev. Search this channel for “multipl...

M

Matt Silverlock•11/1/24, 1:48 PM

workflows

S

Sam•11/1/24, 8:26 PM

Can I add my workflow definition to my existing hono cloudflare worker that contains all my other api logic, or do I need to set this up as a new project?

SSam Can I add my workflow definition to my existing hono cloudflare worker that cont...

M

makrdev•11/1/24, 8:29 PM

Yes, you can add as bindings. Also, you can create an endpoint to manage your workflow by reaching your instance. You can start, pause or resume your workflow via that hono endpoint.

D

dattaproffs•11/2/24, 7:51 PM

hi, trying to add workflows like this in wrangler.toml

workflows = [
  {name = "first-workflow", class_name = "FirstWorkflow", binding = "WORKFLOW_ONE"},
  {name = "second-workflow", class_name = "SecondWorkflow", binding = "WORKFLOW_TWO"}
]

workflows = [
  {name = "first-workflow", class_name = "FirstWorkflow", binding = "WORKFLOW_ONE"},
  {name = "second-workflow", class_name = "SecondWorkflow", binding = "WORKFLOW_TWO"}
]

workflows = [
  {name = "first-workflow", class_name = "FirstWorkflow", binding = "WORKFLOW_ONE"},
  {name = "second-workflow", class_name = "SecondWorkflow", binding = "WORKFLOW_TWO"}
]

workflows = [
  {name = "first-workflow", class_name = "FirstWorkflow", binding = "WORKFLOW_ONE"},
  {name = "second-workflow", class_name = "SecondWorkflow", binding = "WORKFLOW_TWO"}
]

i have it under a [[env.staging]]
if i have one i works but with two the worker failes to start
"The Workers runtime failed to start. There is likely additional logging output above."

there is no error in the log. what am i missing?

Ddattaproffs hi, trying to add workflows like this in wrangler.toml ``` workflows = [ {name...

D

dattaproffs•11/2/24, 7:55 PM

Ok, seems like i posted to fast and there is an answer above. Bug in local dev(?) any timeframe in getting that in dev hands?

Ddattaproffs Ok, seems like i posted to fast and there is an answer above. Bug in local dev(?...

F

fry69•11/2/24, 7:56 PM

Cloudflare does not do ETAs

F

fry69•11/2/24, 7:57 PM

:soontm:

Ffry69 Cloudflare does not do ETAs 🙂

D

dattaproffs•11/2/24, 7:57 PM

haha fair ^^

S

srb•11/2/24, 10:24 PM

feel like i must be doing something stupid but trying to run the workflows-starter and getting a 500 when trying to create a workflow:

[wrangler:inf] GET / 500 Internal Server Error (48ms)
[wrangler:inf] GET /favicon.ico 404 Not Found (2ms)
id null
creating new instance RpcStub {}
[wrangler:err] TypeError: Cannot destructure property 'id' of 'undefined' as it is undefined.
    at async Object.fetch (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/src/index.ts:84:18)
    at async jsonError (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-miniflare3-json-error.ts:22:10)
    at async drainBody (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-ensure-req-body-drained.ts:5:10)

[wrangler:inf] GET / 500 Internal Server Error (48ms)
[wrangler:inf] GET /favicon.ico 404 Not Found (2ms)
id null
creating new instance RpcStub {}
[wrangler:err] TypeError: Cannot destructure property 'id' of 'undefined' as it is undefined.
    at async Object.fetch (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/src/index.ts:84:18)
    at async jsonError (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-miniflare3-json-error.ts:22:10)
    at async drainBody (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-ensure-req-body-drained.ts:5:10)

[wrangler:inf] GET / 500 Internal Server Error (48ms)
[wrangler:inf] GET /favicon.ico 404 Not Found (2ms)
id null
creating new instance RpcStub {}
[wrangler:err] TypeError: Cannot destructure property 'id' of 'undefined' as it is undefined.
    at async Object.fetch (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/src/index.ts:84:18)
    at async jsonError (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-miniflare3-json-error.ts:22:10)
    at async drainBody (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-ensure-req-body-drained.ts:5:10)

[wrangler:inf] GET / 500 Internal Server Error (48ms)
[wrangler:inf] GET /favicon.ico 404 Not Found (2ms)
id null
creating new instance RpcStub {}
[wrangler:err] TypeError: Cannot destructure property 'id' of 'undefined' as it is undefined.
    at async Object.fetch (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/src/index.ts:84:18)
    at async jsonError (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-miniflare3-json-error.ts:22:10)
    at async drainBody (file:///Users/srb/projects/elater-cf-workflow/workflows-starter/node_modules/wrangler/templates/middleware/middleware-ensure-req-body-drained.ts:5:10)

will thread the rest of my src code. is there a specific url you're supposed to hit or something?

S

surgery18•11/3/24, 4:24 AM

Hey guys, within the run function of the workflowentry point, how do you get the current id of the workflow? Is it within this.ctx or something? Thanks.

MMatt Silverlock You will need to deploy a Worker with your Workflow; you can’t bundle it into yo...

Z

zuegno•11/3/24, 3:45 PM

Hello, I've redeployed the remix-template with a worker and workflow following the latest remix template available to support Workers deployment instead of Pages. The same error message

Worker "workflows:demg-test-workflow"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "TestWorkflow", but "core:user:" has no such named entrypoint.

Worker "workflows:demg-test-workflow"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "TestWorkflow", but "core:user:" has no such named entrypoint.

Worker "workflows:demg-test-workflow"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "TestWorkflow", but "core:user:" has no such named entrypoint.

Worker "workflows:demg-test-workflow"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "TestWorkflow", but "core:user:" has no such named entrypoint.

occurred. I've created a minimal repo to recreate and added the full log message in this issue FYI. https://github.com/micksabox/remix-cloudflare-workflows/issues/1

GitHub

Failing deploy · Issue #1 · micksabox/remix-cloudflare-workflows

wrangler 3.84.0 (update available 3.84.1) ------------------------------------------------------- Running custom build: pnpm build > demg-remix@ build /Users/michaelnolivos/Documents/Projects...

Ssurgery18 Hey guys, within the run function of the workflowentry point, how do you get the...

S

surgery18•11/3/24, 7:00 PM

Anyone know how to fetch the instance id of the workflow of itself within the run function of the workflow? Thanks.

Ssurgery18 Anyone know how to fetch the instance id of the workflow of itself within the ru...

J

Jeremy•11/4/24, 1:42 AM

Boosting this. I was not able to find a way to programmatically fetch the workflow id either.

J

jordanfinners•11/4/24, 11:00 AM

Is there a way to delete a workflow? Used onto to send messages onto a queue and some during testing and want to just clean them up for my OCD

Jjordanfinners Is there a way to delete a workflow? Used onto to send messages onto a queue and...

F

fry69•11/4/24, 11:02 AM

I guess that is still not possible -> workflows

AAvi what does the workflow concurrency limit mean? does that mean that if I have 5k ...

D

Diogo Ferreira•11/4/24, 11:42 AM

just to clarify, it means that if you have 5k queued (scheduled workflows pass to queued, once they are intended to be run), 100 will be initially instructed to run, and as they complete, more will run?

Ssurgery18 Anyone know how to fetch the instance id of the workflow of itself within the ru...

D

Diogo Ferreira•11/4/24, 11:53 AM

This is not possible for the moment

DDiogo Ferreira This is not possible for the moment

S

surgery18•11/4/24, 7:52 PM

Ah ok. Well, something you guys can add then.

A

akhilravidas•11/5/24, 3:22 AM

hi! what is the unit of delay field in WorkflowStepConfig if its a number. the documentation at https://developers.cloudflare.com/workflows/build/sleeping-and-retrying/ says default is 10000 - is this ms?

Cloudflare Docs

Sleeping and retrying | Cloudflare Workflows docs

This guide details how to sleep a Workflow and/or configure retries for a Workflow step.

S

skip•11/5/24, 7:45 AM

Hi

. Does anyone have a demo Remix repo I could learn from? (using remix-run/remix/templates/cloudflare-workers)

I have tried following @Craig's "punderful-workflows" example, and kept it very simple in the wrangler and the "main" JS file (following his example, but in a Remix repo)....

But no matter what I do, I always come up against this error....

Worker "workflows:interaction"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "InteractionWorkflow", but "core:user:" has no such named entrypoint.

Worker "workflows:interaction"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "InteractionWorkflow", but "core:user:" has no such named entrypoint.

Worker "workflows:interaction"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "InteractionWorkflow", but "core:user:" has no such named entrypoint.

Worker "workflows:interaction"'s binding "USER_WORKFLOW" refers to service "core:user:" with a named entrypoint "InteractionWorkflow", but "core:user:" has no such named entrypoint.

If someone has a repo with workflows in a Remix setting, that would be much appreciated

Sskip Hi 👋. Does anyone have a demo Remix repo I could learn from? (using remix-run/...

S

skip•11/5/24, 1:03 PM

Ah, just noticed @myconull asked the same question two days ago: workflows.

He's also using Remix as just Worker (not Pages). Could someone on the cloudflare team have a look at his repo, pls?

Sskip Ah, just noticed @myconull asked the same question two days ago: https://discord...

M

Matt Silverlock•11/5/24, 1:18 PM

You can’t deploy a Workflow as part of a Pages app (which is likely what the default Remix build is trying to do).

Deploy the Workflow separately (as a Worker) and bind to it from your Pages app / call it over HTTP.

A

aulneau•11/5/24, 6:43 PM

I've been digging into workflows a lot, but recently I've been getting this error:

The destination execution context for this RPC was canceled while the call was still running.

The destination execution context for this RPC was canceled while the call was still running.

The destination execution context for this RPC was canceled while the call was still running.

The destination execution context for this RPC was canceled while the call was still running.

I can't seem to figure out, how do I limit the amount of instances per minute a workflow can ingest?

Similar Threads

Similar Threads

Similar Threads