Hello, awesome library and great work, much better then the alternatives. I have a couple of questions, how can we insert a custom thread_id in a function decorated flow. And how can we add custom handlers to a flow, for streaming results to a graphql subscription?
j
Jeremiah
10/16/2024, 4:08 PM
Hi @David! See here for docs on handlers which fire on a variety of events
Jeremiah
10/16/2024, 4:12 PM
on the thread id -- someone just pointed out there's a bug in parsing the decorator arguments and i'll try to get a patch release out shortly to fix
d
David
10/16/2024, 6:07 PM
Thanks for the answers. How can I set the handlers in a @flow decorated function? The documentation only mentions cf.run. But when I call a decorated flow function I cannot set the handlers, neither in the Flow class itself. So its a bit confusing.
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.