zlacker

[parent] [thread] 2 comments
1. mfrye0+(OP)[view] [source] 2024-03-08 21:54:12
I've been looking for this exact thing for awhile now. I'm just starting to dig into the docs and examples, and I have a question on workflows.

I have an existing pipeline that runs tasks across two K8 clusters and share a DB. Is it possible to define steps in a workflow where the step run logic is setup to run elsewhere? Essentially not having an inline run function defined, and another worker process listening for that step name.

replies(1): >>abelan+6E
2. abelan+6E[view] [source] 2024-03-09 04:50:19
>>mfrye0+(OP)
This depends on the SDK - both Typescript and Golang support a `registerAction` method on the worker which basically let you register a single step to only run on that worker. You would then call `putWorkflow` programmatically before starting the worker. Steps are distributed by default so they run on the workers which have registered them. Happy to provide a more concrete example for the language you're using.
replies(1): >>mfrye0+1a2
◧◩
3. mfrye0+1a2[view] [source] [discussion] 2024-03-09 22:45:46
>>abelan+6E
Perfect. Yeah, we're using both, but mainly TS. We'll test that out.
[go to top]