my workflow is received multiple signals and each signal is running a sigle activity, i have set workflow to continue as new when wf continueAsNewSuggested is true. i try to send concurrent signal. this my code below try { let isClose = false; wf.setHandler(arrowBill, async (kind: string, b…

after several tries i decided to use a child workflow. this my code bellow try { let isClose = false; wf.setHandler(arrowBill, async (kind: string, bill: Bill) => { try { await wf.startChild(childArrowBill, { workflowId: `childArrowBill-${kind}-${bill.reference}`, …

I’m not sure how child workflows help here and why you need an external signal to decide when to continue as new. what is best way to handle concurrent signals at once? Invoke their handling logic from the handler. I’m not sure I understand the question here. what is best way to close e work…

[image] dwi_wahyu: then, i try again to concurrent send signal but workflow not continue as new until workflow can’t received a signal anymore. Can you explain what you mean by “until workflow can’t received a signal anymore”? Do you mean that the workflow is not calling continueAsNew while …

why you need an external signal to decide when to continue as new. i use external signal to decide continue as new, because in code bellow the workflow is not continue as new if (wf.workflowInfo().continueAsNewSuggested) { await wf.condition(wf.allHandlersFinished); await wf.continueAsNew…

correct, the workflow is not continueAsNew. i see, but if the signal received slows down at some point, will allHandlersFinished return true? in my case, how to safe way continueAsNew?

That depends on how fast you’re sending signals and how long your signal handlers are taking to run your activities to handle the signal. If no signals arrive for long enough so that all your current signal handlers finish, then I imagine at that point allHandlersFinished would return true because …

can you provide a code sample or reference how to do buffering and process it in new workflow after receiving signal?

I think there was a code example somewhere but I don’t remember where now. Something like let draining = false; let buffered_signals = []; wf.setHandler(arrowBill, async (kind: string, bill: Bill) => { if (draining) { buffered_signals.push({type: "arrowBill", kind, bill}); return; } …

Pending activities when continue as new

Community Support

dwi_wahyu June 24, 2025, 4:25am 11

thanks, i will try it

Topic		Replies	Views
Python Continue-as-new and signals draining Community Support python-sdk , signals , continue-as-new	7	257	June 16, 2025
A safe way to send a signal to a long-running workflow? Community Support typescript-sdk	6	1010	July 7, 2024
ContinueAsNew + signals Community Support go-sdk	36	8218	November 15, 2022
TS SDK signals and continueAsNew Community Support typescript-sdk	5	1627	April 19, 2022
Possible race condition between signalWithStart and continueAsNew? Community Support signals , typescript-sdk	4	1005	December 16, 2022

Pending activities when continue as new

Related topics