Chris Keeley
04/11/2022, 1:09 PMwait_for_flow_run
method for creating flow of flows, but this seems designed to work with one tenantKevin Kho
client = Client(api_key=other_tenant_key)
client.create_flow_run(flow_run_id)
but all of the tasks are designed with one tenant in mind because they just pull the Client from context. For example, wait_for_flow_run
uses a Client that it just pulls. This means that if you wanted to do something like wait_for_flow_run
, you’d need to write a new task that can use another Client.
So triggering a flow seems easy but the waiting seems hard. If you just have to trigger, it feels doable.Anders Segerberg
04/11/2022, 3:07 PMwait_for_flow_run
because it had a default timeout of 12 hours, and I have longer runtimes. Will this limitation ever be made configurable?Kevin Kho
Anders Segerberg
04/11/2022, 4:13 PMKevin Kho
Anders Segerberg
04/11/2022, 4:15 PMKevin Kho
Anders Segerberg
04/11/2022, 4:18 PMChris Keeley
04/13/2022, 10:37 AMclient = Client()
was helpful.
I just had to write a task which polls using a provided client, giving a RETRY signal if it's not ready. and extracted some graphql queries from the source to do it against my own client.