Chris Keeley04/11/2022, 1:09 PM
method for creating flow of flows, but this seems designed to work with one tenant
but all of the tasks are designed with one tenant in mind because they just pull the Client from context. For example,
client = Client(api_key=other_tenant_key) client.create_flow_run(flow_run_id)
uses a Client that it just pulls. This means that if you wanted to do something like
, 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 Segerberg04/11/2022, 3:07 PM
because it had a default timeout of 12 hours, and I have longer runtimes. Will this limitation ever be made configurable?
Anders Segerberg04/11/2022, 4:13 PM
Anders Segerberg04/11/2022, 4:15 PM
Anders Segerberg04/11/2022, 4:18 PM
Chris Keeley04/13/2022, 10:37 AM
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.
client = Client()