Can I add my workflow definition to my existing hono cloudflare worker that contains all my other ap

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.

MMatt Silverlock You can’t deploy a Workflow as part of a Pages app (which is likely what the def...

Z

zuegno•11/5/24, 7:20 PM

Hi Matt, the repo that I posted is using the latest Cloudflare Remix template using Workers instead of pages. And the issue was still occuring.

W

Walshy•11/5/24, 7:22 PM

The Remix template is currently building as a Pages project then deploying as a Worker which is likely why this is happening. Remix has native support for Assets now so we're moving that over, you can track that here: https://github.com/cloudflare/workers-sdk/pull/7170

WWalshy The Remix template is currently building as a Pages project then deploying as a ...

S

skip•11/6/24, 1:44 AM

Ah thanks for the reply. Can I ask - what determines Pages vs Worker? I was previously looking for "pages_build_output_dir " in .wrangler

D

DoggeSlapper•11/6/24, 4:06 PM

I'm trying to understand how can I get workflow step by workflow id or is not possible?

D

DoggeSlapper•11/6/24, 4:21 PM

wrangler workflows instances describe

wrangler workflows instances describe

there is no equivalent for local right?

M

mau•11/6/24, 8:18 PM

No automatic unique id is generate when create method is called without id. Is it a usual behaviour or a bug in local?

M

mau•11/6/24, 9:05 PM

I’m exploring Cloudflare Workflows to streamline email notifications for parents on our e-learning platform. Our goal is to notify parents based on specific events they’ve subscribed to, like when a student completes a quiz, finishes a topic, or needs a daily/weekly family summary. We want to set these notifications to trigger at defined times, tailored to each user’s preferences. If anyone has insights or tips on setting up these kinds of recurring notifications effectively, I’d love to hear them!

Thanks in advance for your help!

D

Dmitry•11/7/24, 5:02 AM

Was doing some load tests and noticed that if I start a bunch of workflows quickly the dashboard kinda becomes really slow

D

Dmitry•11/7/24, 5:02 AM

Anyone else experience this?

D

Dmitry•11/7/24, 5:02 AM

I was only starting like 26/s tho

D

Dmitry•11/7/24, 5:03 AM

Once I stop the load test and wait a few min for the workflows to finish .. it loads fine

O

oof2win2•11/7/24, 6:22 AM

is there some concurrency limit for workflows, and after that the ability to queue in items for processing? i have a cronjob that potentially fetches a lot of data to be processed at once and i want to send it to a workflow, but i don't want to hit the concurrency limit

DDiogo Ferreira just to clarify, it means that if you have 5k queued (scheduled workflows pass t...

O

oof2win2•11/7/24, 6:23 AM

this seems like exactly what i want but i can't seem to find the answer

O

oof2win2•11/7/24, 8:19 AM

additionally is there a way to limit the amount of concurrent workflow runs overall? like if i have 100 waiting for API calls it won't start up more?

Ooof2win2 additionally is there a way to limit the amount of concurrent workflow runs over...

M

makrdev•11/7/24, 10:24 AM

Nope, not yet. I think they are working on it.

DDmitry Was doing some load tests and noticed that if I start a bunch of workflows quick...

S

Seekerdasbatatas•11/7/24, 3:14 PM

we are aware of the performance issue and hopefully fixing it very :soonsoontm:

A

Avi•11/7/24, 8:32 PM

A

Avi•11/7/24, 8:32 PM

we're seeing a LOT of these "Attempt failed due to internal workflows error" failures

A

Avi•11/7/24, 8:33 PM

for days, in a great many of our workflow instances

A

Avi•11/7/24, 8:33 PM

is anyone else seeing this? does anyone have insight into what these errors are?

AAdvany I am trying to extract some data from a html page using html rewriter: ``` var ...

O

oof2win2•11/8/24, 12:06 AM

hey there. i'm working with a HTMLRewriter and i seem to be getting errors with an RPC stub not being disposed. i think it's the rewriter because of essentially the same error here. is this an issue on my side or an issue within workers?

D

Dmitry•11/8/24, 1:54 AM

I also noticed... I have a sleep step like so

await step.sleep('wait on something', '1 second')

await step.sleep('wait on something', '1 second')

but here it says the wall time for this step is

254ms

254ms

.. any idea why it's lower than what the wall time should be?

D

Dmitry•11/8/24, 1:56 AM

it would also be nice if it showed the sleep step name (i.e - "wait on something").. even tho it is just a sleep.. instead of just showing the name as "Sleep"

D

Dmitry•11/8/24, 1:57 AM

Maybe like

wait on something (Sleep)

wait on something (Sleep)

D

Dmitry•11/8/24, 1:58 AM

It's easy to tell what sleep step it is, since I only have 1 sleep step.. but if I had multiple.. it would be easier to tell which sleep step is what very quickly

A

arbfay•11/8/24, 12:40 PM

I hit a wall with Workflows:

Serialized RPC arguments or return values are limited to 1MiB

Serialized RPC arguments or return values are limited to 1MiB

which I think happens when the returned values of a step are larger than 1MiB.

What is the workaround for worklows? For service bindings, it is to use streams.

A

arbfay•11/8/24, 1:12 PM

Yeah merged 3 steps into 1. Not ideal.

Aarbfay Yeah merged 3 steps into 1. Not ideal.

S

Seekerdasbatatas•11/8/24, 2:04 PM

wdym? in theory you can save/load in a different storage provider without compromising granularity

SSeekerdasbatatas wdym? in theory you can save/load in a different storage provider without compro...

A

arbfay•11/8/24, 3:02 PM

It's just a lot faff to add R2/offloading (not being used in this project).

Can I add my workflow definition to my existing hono cloudflare worker that contains all my other ap

Similar Threads

Similar Threads

Similar Threads