Effect CommunityEC
Effect Community6mo ago
4 replies
jrmdayn

Unexpected `Interrupt` replies being persisted could indicate an issue with how interruptions are...

I have a workflow A that triggers another workflow B multiple times:
const [fail, success] = yield* Effect.partition([1,2,3,...], id => B.execute({id}), { concurrency: 10 } )
...


After a while, A fails because one of B runs has failed. Using partition I would expect A to not fail. Looking at the replies table, i can see one of B runs resulted in a weird persisted Interrupt response (see error in thread). Looking at the reply for A, it has a similar Interrupt error.

Is it normal that Interrupt replies are persisted? I would expect not since interruption is occurring everytime a pod is stopped. Maybe I am missing something..

I am using:
"effect": "3.16.12",
"@effect/workflow": "0.4.13",
"@effect/cluster": "0.41.17",
Was this page helpful?