I am encountering the following error while creating a Workflow. ``` DataCloneError: Could not seri

Lluiseok I am encountering the following error while creating a Workflow. ``` DataCloneE...

M

State can only be objects that are Serializable. You’re trying to return an

Instance

Instance

object, which is not (it has methods).

Just return the

id

id

.

MMatt Silverlock State can only be objects that are Serializable. You’re trying to return an `Ins...

L

luiseokOP•3/13/25, 12:21 PM

Thanks Matt. I was able to fix the issue by returning only

id

id

A

Alex Patterson•3/13/25, 3:30 PM

Can someone confirm that workflows are blocking? With "create" I was expecting they would run in their own service and then later I would poll to see if they have been updated. But in reality they are blocking my API call. I think will probably have to introduce queues as well if this is the case.

// Start workflows
c.env.COVE_WORKFLOW_VIDEO_UPLOAD_STREAM.create({
    params: {
        videoId: id,
    },
});
c.env.COVE_WORKFLOW_VIDEO_TRANSCRIPT.create({
    params: {
        videoId: id,
    },
});

// Start workflows
c.env.COVE_WORKFLOW_VIDEO_UPLOAD_STREAM.create({
    params: {
        videoId: id,
    },
});
c.env.COVE_WORKFLOW_VIDEO_TRANSCRIPT.create({
    params: {
        videoId: id,
    },
});

// Start workflows
c.env.COVE_WORKFLOW_VIDEO_UPLOAD_STREAM.create({
    params: {
        videoId: id,
    },
});
c.env.COVE_WORKFLOW_VIDEO_TRANSCRIPT.create({
    params: {
        videoId: id,
    },
});

// Start workflows
c.env.COVE_WORKFLOW_VIDEO_UPLOAD_STREAM.create({
    params: {
        videoId: id,
    },
});
c.env.COVE_WORKFLOW_VIDEO_TRANSCRIPT.create({
    params: {
        videoId: id,
    },
});

AAlex Patterson Can someone confirm that workflows are blocking? With "create" I was expecting t...

A

Aslak Hellesoy•3/13/25, 6:26 PM

They're not blocking. Workflow.create returns a WorkflowInstance - and it returns before the workflow has completed.

A

Aslak Hellesoy•3/13/25, 6:29 PM

Has anyone managed to get logs from workflows? When a workflow step fails, there is no stack trace in the Cloudflare dashboard - only the error message is displayed.

I've tried to integrate

@sentry/cloudflare

@sentry/cloudflare

, but from what I can tell it only provides high level wrappers for fetch requests and pages - I can't figure out how to make a cloudflare logger instance.

M

Matt Silverlock•3/14/25, 2:18 AM

Do you have an example? They should show up in logs under the Worker script - if you have

observability.enabled: true

observability.enabled: true

.

Y

Yuuseiran•3/14/25, 5:04 AM

hey pals. I'm kinda new to workflows, as per the documentation, restarting a workflow via the restart() function is not supported and will throw an error. is there a way to restart an instance? also can i trigger a restart on a errored instance?

N

nejc•3/14/25, 9:43 AM

Hi all, I have a workflow that accepts 1000 leds for example and then for each lead needs to do two steps and then call callback. Is there a cleaner way to do this flow, because my worry is that things will get mixed around when retries kick in. This is pseudo code:

for (const lead of leads) {
  const result = await Promise.all([step.do('Step 1', async () => {}), step.do('Step 2', async () => {})])

  await step.do('callback', async () => { /* callback with a result */})
}

for (const lead of leads) {
  const result = await Promise.all([step.do('Step 1', async () => {}), step.do('Step 2', async () => {})])

  await step.do('callback', async () => { /* callback with a result */})
}

for (const lead of leads) {
  const result = await Promise.all([step.do('Step 1', async () => {}), step.do('Step 2', async () => {})])

  await step.do('callback', async () => { /* callback with a result */})
}

for (const lead of leads) {
  const result = await Promise.all([step.do('Step 1', async () => {}), step.do('Step 2', async () => {})])

  await step.do('callback', async () => { /* callback with a result */})
}

M

Murder Chicken•3/14/25, 4:16 PM

Is it possible to trigger a workflow-B from within a workflow-A?

MMurder Chicken Is it possible to trigger a workflow-B from within a workflow-A?

C

Chris Jayden•3/14/25, 4:29 PM

Yes.

M

Murder Chicken•3/14/25, 4:32 PM

Interesting, how would that be configured in the wrangler.toml as a binding?

M

Murder Chicken•3/14/25, 4:45 PM

Because a workflow has a configuration in it's

toml

toml

like this:

[[workflows]]
name = "workflow-a"
binding = "WORKFLOW_A"
class_name = "WorkflowA"

[[workflows]]
name = "workflow-a"
binding = "WORKFLOW_A"
class_name = "WorkflowA"

But if

workflow B

workflow B

needs to have a binding in

workflow A

workflow A

, where does that binding go? Just another

[[workflows]]

[[workflows]]

entry? If so, that seems to fail as it would expect the

class_name

class_name

reference to exist in

workflow A

workflow A

's index.

Kkchro3 Seeing this error: ``` { "$workers": { "diagnosticsChannelEvents": [], ...

R

rodrigo•3/14/25, 5:23 PM

anyone figured out what causes this error? We are still seeing this regularly on our logs but the corresponding workflow executes normally.

Screenshot_2025-03-14_at_10.23.27_AM.png

Aalex (he/him)Found this https://developers.cloudflare.com/workflows/build/workers-api/#cross-...

M

Murder Chicken•3/14/25, 6:56 PM

Were you ever able to get this to work as-documented?

MMurder Chicken Because a workflow has a configuration in it's `toml` like this: ``` [[workflows...

F

flash716•3/14/25, 6:58 PM

Are these workflows in different Workers?

M

Murder Chicken•3/14/25, 6:58 PM

Yes.

M

Murder Chicken•3/14/25, 6:59 PM

The first worker is only invoked via scheduled handler but in workflow's last step, I need to kick off another workflow.

M

Murder Chicken•3/14/25, 7:02 PM

If I try and use cross-script calls like in the documentation...

WORKER A wrangler.toml

[[workflows]]
name = "workflow-a"
binding = "WORKFLOW_A"
class_name = "WorkflowA"

[[workflows]]
name = "workflow-b"
binding = "WORKFLOW_B"
class_name = "WorkflowB"
script_name = "workflow-b"

[[workflows]]
name = "workflow-a"
binding = "WORKFLOW_A"
class_name = "WorkflowA"

[[workflows]]
name = "workflow-b"
binding = "WORKFLOW_B"
class_name = "WorkflowB"
script_name = "workflow-b"

[[workflows]]
name = "workflow-a"
binding = "WORKFLOW_A"
class_name = "WorkflowA"

[[workflows]]
name = "workflow-b"
binding = "WORKFLOW_B"
class_name = "WorkflowB"
script_name = "workflow-b"

[[workflows]]
name = "workflow-a"
binding = "WORKFLOW_A"
class_name = "WorkflowA"

[[workflows]]
name = "workflow-b"
binding = "WORKFLOW_B"
class_name = "WorkflowB"
script_name = "workflow-b"

WORKER B wrangler.toml

[[workflows]]
name = "workflow-b"
binding = "WORKFLOW_B"
class_name = "WorkflowB"

[[workflows]]
name = "workflow-b"
binding = "WORKFLOW_B"
class_name = "WorkflowB"

I get the following error (like other users are reporting)...

✘ [ERROR] Worker "workflows:workflow-b"'s binding "USER_WORKFLOW" refers to a service "core:user:workflow-b", but no such service is defined.

✘ [ERROR] Worker "workflows:workflow-b"'s binding "USER_WORKFLOW" refers to a service "core:user:workflow-b", but no such service is defined.

It's worth noting that

USER_WORKFLOW

USER_WORKFLOW

is not a string that exists in my codebase, at all. NOTE: Found a reference to

USER_WORKFLOW

USER_WORKFLOW

in the

workers-sdk

workers-sdk

codebase: https://github.com/cloudflare/workers-sdk/blob/99f802591e65a84f509a03a4071030eb0c6c11ba/packages/miniflare/src/plugins/workflows/index.ts#L77

M

Murder Chicken•3/14/25, 7:04 PM

Both workflows work just fine if invoked on their own. It's when I try to configure one to be called from the other where I run into issues.

A

ajgeiss0702•3/15/25, 12:35 AM

is an option for limiting workflow concurrency on the roadmap? I would love to move a bunch of stuff over to workflows, but I don't want to overwhelm some small external apis i call, which is what I currently use queues for

K

kchro3•3/15/25, 6:54 PM

Hey folks, we continue to see error logs for our workflow that just say "run". if I filter by request ID, I can see that the workflow successfully executed other steps, so I don't know where the "run" error log is coming from.

Kkchro3 Hey folks, we continue to see error logs for our workflow that just say "run". i...

C

Chaika•3/15/25, 7:59 PM

it's just how the workflow invocations show

C

Chaika•3/15/25, 8:00 PM

https://discord.com/channels/595317990191398933/1303411588929294358/1303488051917492318

K

kchro3•3/15/25, 8:00 PM

Are they supposed to be shown as errors?

C

Chaika•3/15/25, 8:01 PM

They're not supposed to, the workflow team as in that msg wants to fix it, but they currently all do

Rrodrigo anyone figured out what causes this error? We are still seeing this regularly on...

C

Chaika•3/15/25, 8:03 PM

same as above ^, as said in the thread "for now I'd just look at the workflows page to see how your instances are doing."

K

Khafra•3/15/25, 11:55 PM

Hi, is it possible to set the retry steps after a workflow fails? For example one of my workflow steps calls a third party api where I don't know the ratelimits. I want to fail the step if I'm ratelimited, but then retry at a specific date (the api gives us this date if we're ratelimited).

I can think of some ideas like

for (const param of params) {
  while (true) {
    const response = await step.do('<random name>', { /* options to not retry */ }, ...)

    if (response.status === 429) {
      await step.sleep('ratelimit expires', Number(response.headers.get('X-RateLimit-Reset')) * 1000)
    } else {
      break
    }
  }
}

for (const param of params) {
  while (true) {
    const response = await step.do('<random name>', { /* options to not retry */ }, ...)

    if (response.status === 429) {
      await step.sleep('ratelimit expires', Number(response.headers.get('X-RateLimit-Reset')) * 1000)
    } else {
      break
    }
  }
}

for (const param of params) {
  while (true) {
    const response = await step.do('<random name>', { /* options to not retry */ }, ...)

    if (response.status === 429) {
      await step.sleep('ratelimit expires', Number(response.headers.get('X-RateLimit-Reset')) * 1000)
    } else {
      break
    }
  }
}

for (const param of params) {
  while (true) {
    const response = await step.do('<random name>', { /* options to not retry */ }, ...)

    if (response.status === 429) {
      await step.sleep('ratelimit expires', Number(response.headers.get('X-RateLimit-Reset')) * 1000)
    } else {
      break
    }
  }
}

but I'm wondering if there's anything better?

K

Khafra•3/16/25, 12:03 AM

maybe a DurableObject is better in this case

KKhafra Hi, is it possible to set the retry steps *after* a workflow fails? For example ...

M

Matt Silverlock•3/16/25, 12:55 AM

Call

step.sleep

step.sleep

within the step when you get a rate limiting error? with the argument as the future Date?

K

Khafra•3/16/25, 12:55 AM

it never even crossed my mind to have nested steps lol

K

Khafra•3/16/25, 12:59 AM

this changes everything

M

Matt Silverlock•3/16/25, 1:07 AM

Workflows: it's just code

A

ajay | dreamlit.ai•3/17/25, 2:30 PM

I have a workflow run that appears to be stuck in "RUNNING" state. Here's what the dashboard shows for the run.

Any idea on what might be up? As you can see there's both a timeout and retry for this step, both of which appear to be ignored.

Aajay | dreamlit.ai I have a workflow run that appears to be stuck in "RUNNING" state. Here's what t...

M

Matt Silverlock•3/17/25, 8:42 PM

Timeout is per step... with

total retries before it will terminally fail.

2 minute

2 minute

is not the total time for all retries.

Aajay | dreamlit.ai I have a workflow run that appears to be stuck in "RUNNING" state. Here's what t...

M

Matt Silverlock•3/17/25, 8:50 PM

And by "stuck" - have you attempted to call

.stop

.stop

on the instance? What error do you get (if any) when you call

terminate

terminate

in the dash?

MMatt Silverlock Timeout is per step... with `20160` total retries before it will terminally fail...

A

ajgeiss0702•3/17/25, 10:24 PM

wouldn't the dashboard show if there were other retries though? it looked like that one step's first try had been running for at least an hour based on that timestamp

T

Txantonnikole•3/18/25, 1:17 AM

MMurder Chicken Were you ever able to get this to work as-documented?

A

alex (he/him)•3/18/25, 6:37 AM

Yeah but only running the workers with the same command

wrangler -c ... -c ...

wrangler -c ... -c ...

locally

CChaika They're not supposed to, the workflow team as in that msg wants to fix it, but t...

K

kchro3•3/18/25, 4:15 PM

is it possible to handle these exceptions so that they don't flood our metrics dashboard?

A

Advany•3/19/25, 1:03 PM

I am looping over a json array. each step does some api calls and changes the item inside the json. But somehow the steps are overwriting each other sometimes and I loose progress from previous steps.

I get the json using a step and then create a loop to go over the array inside jte json and for each item I call the step again.

How can I prevent steps from overriding each other

AAdvany I am looping over a json array. each step does some api calls and changes the it...

H

Hello, I’m Allie!•3/19/25, 2:42 PM

What do the steps in the loop return?

MMatt Silverlock Timeout is per step... with `20160` total retries before it will terminally fail...

A

ajay | dreamlit.ai•3/19/25, 2:50 PM

Right, we should have expected retry functionality there correct? It appears that it was in that stuck in that

Running

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

Terminated

, the step status still says

Running

Running

. See screenshot. Perhaps I've misconfigured something?

Thank you for your help!

HHello, I’m Allie!What do the steps in the loop return?

A

Advany•3/20/25, 12:29 PM

fixed it! I make the loop part of a bigger step and get and set base don that!

O

omar•3/20/25, 1:28 PM

I'm getting an error fetching a file from R2 within my workflow

[ERROR] Uncaught (in promise) DOMException

[ERROR] Uncaught (in promise) DOMException

  const file = await step.do("get file from R2", async () => {
    return this.env.STATEMENT_BUCKET.get(fileIdentifier)
  });

  const file = await step.do("get file from R2", async () => {
    return this.env.STATEMENT_BUCKET.get(fileIdentifier)
  });

  const file = await step.do("get file from R2", async () => {
    return this.env.STATEMENT_BUCKET.get(fileIdentifier)
  });

  const file = await step.do("get file from R2", async () => {
    return this.env.STATEMENT_BUCKET.get(fileIdentifier)
  });

Oomar I'm getting an error fetching a file from R2 within my workflow ```[ERROR] Uncau...

H

Hello, I’m Allie!•3/20/25, 1:34 PM

I’m guessing that’s probably because an R2 file is not serializable

J

JMPA•3/20/25, 9:17 PM

do you know where can i found a example code with impaiting working?

J

JMPA•3/20/25, 9:18 PM

thats will be easier...

SSeekerdasbatatas I have a PR to get `vitest-pool-workers` to not crash with Workflows: https://gi...

K

kchro3•3/21/25, 8:49 PM

any updates on this? the agents SDK is also exporting workflows for some reason and now my tests are breaking again

AAslak Hellesoy Has anyone managed to get logs from workflows? When a workflow step fails, there...

M

Marco Aleixo•3/22/25, 8:48 PM

hey Aslak, curious if you made progress with sentry integration - I'm working to add sentry in my workflows as well - and we already struggled to instrument Queues...

A

ajay | dreamlit.ai•3/24/25, 3:43 PM

@Marco Aleixo @Aslak Hellesoy spent many hours on getting stack traces to show up in Sentry. Here's what finally worked:

I am encountering the following error while creating a Workflow. ``` DataCloneError: Could not seri

Similar Threads

Similar Threads

Similar Threads