Paco Ibañez
05/12/2022, 8:54 PMZanie
05/12/2022, 8:58 PMPaco Ibañez
05/12/2022, 9:04 PMZanie
05/12/2022, 9:08 PMfrom prefect import get_client, task
@task
async def create_flow_run_from_deployment(deployment_id):
async with get_client() as client:
await client.create_flow_run_from_deployment(deployment_id)
You could use a task like this in the first flow@flow
def my_orchestrator():
create_flow_run_from_deployment("sfasf-sfas-ffsfa-sfas")
Paco Ibañez
05/12/2022, 9:09 PMZanie
05/12/2022, 9:15 PMPaco Ibañez
05/12/2022, 9:20 PM