I think if you need a stub after it has returned its value, you should `dup()` it then `dispose()` o

I think if you need a stub after it has returned its value, you should

dup()

dup()

dup()

dup() it then

dispose()

dispose()

dispose()

dispose() of the original?

11984 Ford Laser I think if you need a stub after it has returned its value, you should `dup()` i...

kchro3•11/28/24, 3:14 AM

got it, thanks

anirudh•11/28/24, 4:57 AM

I want to create a workflow which takes an input of list of APIs to be called. I want to loop over the list and call the API in a step.do, do workflows support this?

alex (he/him)•11/28/24, 10:17 AM

If I rename a workflow binding, it get's added as a new entry to the dashboard.. Is there a way to delete registered workflows? How can I get rid of them in the UI and remove them from the system completely.. otherwise we end up with a lot of stale stuff

Seekerdasbatatas•11/28/24, 11:03 AM

we don't a delete endpoint for workflows - it's coming :soonsoontm:

1984 Ford LaserOP•11/28/24, 11:04 AM

I cant read

alex (he/him)•11/28/24, 1:57 PM

I'm getting this: UNDEFINED_VALUE: Undefined values are not allowedUNDEFINED_VALUE: Undefined values are not allowed
My Params type look like this:

type Params = {
    machine_id: number;
    target_language_id: number;
    techdata_template_id?: number;
    servicedata_template_id?: string;
};

type Params = {
    machine_id: number;
    target_language_id: number;
    techdata_template_id?: number;
    servicedata_template_id?: string;
};

It looks like Workflows does not support optional params, is that correct?

SSeekerdasbatatas we don't a delete endpoint for workflows - it's coming :soonsoontm:

alex (he/him)•11/28/24, 3:12 PM

Sounds good. I have like roughly 10k instances brokenly queued. How to bulk terminate them?

Focux•11/28/24, 3:19 PM

is there a way to know within a step if it's retrying, and if so, can you get the error that made it fail?

alex (he/him)•11/28/24, 7:41 PM

Did we just loose the Wall Time per Step in the Dashboard? It was very nice to see how long a step took for a specific instance

alex (he/him)•11/28/24, 8:16 PM

What are some ideas around reducing state byte size. I'm currently facing an issue where I either reach the step count limit or subrequest limit, so the solution is to combine things, but then I'm facing the size limit. I think the state size limit should be easier to increase maybe to 10MiB?

Serialized RPC arguments or return values are limited to 1MiB, but the size of this value was: 2221149 bytes.

Serialized RPC arguments or return values are limited to 1MiB, but the size of this value was: 2221149 bytes.

Aalex (he/him)What are some ideas around reducing state byte size. I'm currently facing an iss...

Seekerdasbatatas•11/29/24, 10:57 AM

In these cases I would recommend storing the result to KV/R2 and just return the key

SSeekerdasbatatas In these cases I would recommend storing the result to KV/R2 and just return the...

alex (he/him)•11/29/24, 11:12 AM

And retrieving it in the next step again?

Aalex (he/him)And retrieving it in the next step again?

Seekerdasbatatas•11/29/24, 11:16 AM

when you need it yes

Aalex (he/him)And retrieving it in the next step again?

1984 Ford LaserOP•11/29/24, 11:27 AM

KV is usually in single milliseconds for hot reads, overall that shouldn't be an issue

alex (he/him)•11/29/24, 11:36 AM

Good idea, haven’t thought about that approach. I’ll see how it will help

11984 Ford Laser KV is usually in single milliseconds for hot reads, overall that shouldn't be an...

alex (he/him)•11/29/24, 11:38 AM

Yeah I was also thinking about KV instead of R2, I think just making sure to clean-up that KV is important, but otherwise it should be totally fine. It’s a background job, so not too concerned about latency

Focux•11/29/24, 1:38 PM

any idea why i get this error when using this retry policy { retries: { limit: 12, delay: '2s', backoff: 'constant' } }{ retries: { limit: 12, delay: '2s', backoff: 'constant' } }

✘ [ERROR] Uncaught (in promise) Error: NOT NULL constraint failed: priority_queue.target_timestamp: SQLITE_CONSTRAINT

✘ [ERROR] Uncaught (in promise) Error: NOT NULL constraint failed: priority_queue.target_timestamp: SQLITE_CONSTRAINT

Focux•11/29/24, 1:39 PM

If I remove the retry policy then I don't get any error

Focux•11/29/24, 2:22 PM

would it be possible in the future to await a workflow response inside a workflow? like await would sleep your current workflow instance until the sub-workflow finish

FFocux would it be possible in the future to await a workflow response inside a workflo...

Seekerdasbatatas•11/29/24, 2:31 PM

it might (or not) happen in the future, but couldn't you make the sub-workflow trigger another workflow at the end? workflow1 -> sub-workflow -> workflow2

Focux•11/29/24, 2:36 PM

i mean, yeah, that could work, but it would be good to have some kind of child workflow concept, like temporal.io

Focux•11/29/24, 2:37 PM

if the child workflow doesn't succeed then the parent workflow doesn't succeed either

Focux•11/29/24, 2:37 PM

and also it is good for propagating cancellation signals when implemented

Focux•11/29/24, 2:38 PM

and for code organization

Seekerdasbatatas•11/29/24, 2:40 PM

yeah I completely understand, we'll take your feedback into account

micooz•11/29/24, 2:46 PM

How can I processa large zip file (get from R2) across steps (get/unzip/put to R2) ? I saw the maximum persisted state per step is only 1MiB.

Mmicooz How can I processa large zip file (get from R2) across steps (get/unzip/put to R...

Seekerdasbatatas•11/29/24, 2:53 PM

In this case, I think that you're better off making (get, unzip, put to R2) into a single step, although you lose some granularity as long you guarantee idempotency you'll be okay

Carl•11/29/24, 4:07 PM

really loving workflows so far. I hit the execution limit for my use case and had to use a self spawning approach to get around it. Thanks for giving us this primitive. cool stuff

dattaproffs•11/30/24, 5:50 PM

Hi, anyone have a good idea how to fan out and keep track of when all of the fanouts is done to send a webhook.
I want to do a couple of steps and when done send a webhook. The 512 limit is a bit small sometimes and i need to fan out, so how do i best keep track of the workflows. Should i have a orchestrator workflow that spawns the fanouts and keep track that way? Any other good ideas. Thanks

drew•12/2/24, 4:53 PM

Hey there. Is there a limit to the number of workflow instances that can be queued after exceeding the concurrency limit? Trying to understand what the expected behavior is in that case

Carl•12/2/24, 5:16 PM

Hi. I'm facing issues with workflow instances stuck in a queued state indefinitely and i'm unable to terminate it or anything.

kingmesal•12/2/24, 8:58 PM

Does a single workflow instantiation inherit the subrequests limit defined in worker limits?
https://developers.cloudflare.com/workers/platform/limits/

Cloudflare Docs

Limits · Cloudflare Workers docs

Cloudflare Workers plan and platform limits.

CCarl Hi. I'm facing issues with workflow instances stuck in a queued state indefinite...

ddsgadget•12/2/24, 9:50 PM

had the same issue. hope they fix this. I think this is just a bug where the queued state cannot be changed.

tornado•12/2/24, 9:57 PM

The limits page say that the 30 second cpu limit is per step but it seems like the cpu time is actually for the workflow.

ddsgadget•12/2/24, 9:57 PM

Do you have any ETA when the workflows will be out of beta? Just worried about potential changes and the need to refactor. Not sure how much really changes between beta and when it is out of beta. I've never used a Cloudflare beta product before...But really love workflows. Makes so many thing easier.

Kkingmesal Does a single workflow instantiation inherit the subrequests limit defined in wo...

Matt Silverlock•12/2/24, 10:31 PM

Yes.

Dddsgadget Do you have any ETA when the workflows will be out of beta? Just worried about p...

Matt Silverlock•12/2/24, 10:31 PM

We're still very early on - it won't be this year / Jan. Quality > time.

tornado•12/3/24, 4:12 PM

Is there a clear explanation of how cpu limit works? I'm hitting cpu limit in the workflow even though previously the individual steps logic was well within the cpu limit. It seems like the workflow cpu limit is the sum of the steps cpu usage. Also I have a large try, catch to eventually cleanup but it when I get the CPU exceeded error, the last step never runs

tornado•12/3/24, 4:50 PM

Is there a difference between using Promise.all and having a for loop that adds the step output to an array? The array will still be comprised of only step.do returns so that should be fine right?

tornado•12/3/24, 5:37 PM

Please help, my workflow is crashing and not continuing to next steps due to CPU limit exceeded but I do everything inside steps, there is virtually no work done in the workflow itself.

Ttornado Is there a clear explanation of how cpu limit works? I'm hitting cpu limit in th...

Victor•12/3/24, 5:41 PM

https://developers.cloudflare.com/workers/platform/limits/#cpu-time how it's calculated

Cloudflare Docs

Limits · Cloudflare Workers docs

Cloudflare Workers plan and platform limits.

Ttornado Please help, my workflow is crashing and not continuing to next steps due to CPU...

Victor•12/3/24, 5:43 PM

https://developers.cloudflare.com/workflows/reference/limits/ total cpu time of workflow is unlimited, but per step (listed as Compute time per stepCompute time per step) you have 10 seconds (free plan) or 30 seconds (paid plan)

Cloudflare Docs

Limits · Cloudflare Workflows docs

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

tornado•12/3/24, 6:13 PM

Can the return of a step be an instantiated class object or will that cause problems if the workflow restarts at some point?

森

森@VerseLink (RW)•12/4/24, 12:22 AM

Can someone confirm if durable objects never gets evicted if it creates a workflow instance? Will I be billed for durations in DO?

森

森@VerseLink (RW)•12/4/24, 12:25 AM

I tried creating an empty DO and have it invoke a workflow that simply sleeps for 30seconds.

The duration should be enough to evict a DO under normal circumstances, however, when the DO is called from the workflow again (via this.env binding), the DO's constructor was never ran again indicating that the instance never got evicted.

MMatt Silverlock Yes.

inaridiy•12/4/24, 6:12 AM

Is there a good way to alleviate this limitation?
In the meantime, I am going to try the method of calling a child Workflow from a Workflow.

森森@VerseLink (RW)I tried creating an empty DO and have it invoke a workflow that simply sleeps fo...

Matt Silverlock•12/4/24, 8:52 AM

There’s no guarantee that a DO will be slept right on 30 seconds. Try longer. If you need to keep a DO running, use an Alarm. You will (necessarily) pay for the duration.

nixology•12/4/24, 9:16 AM

Played a little with workflows, its very good & useful. Just wondering, I couldn't figure out if I want to use CF Workflows to hook it up to build a workflow builder tool, where user can drag nodes to create a workflow. How to do so? As of now it doesn't seem possible as each step needs to be statically defined.

I think if you need a stub after it has returned its value, you should `dup()` it then `dispose()` o

Similar Threads

Similar Threads

Similar Threads