Paco Ibañez
05/12/2022, 8:54 PMZanie
Zanie
Paco Ibañez
05/12/2022, 9:04 PMZanie
from 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 flowZanie
@flow
def my_orchestrator():
create_flow_run_from_deployment("sfasf-sfas-ffsfa-sfas")
Zanie
Paco Ibañez
05/12/2022, 9:09 PMPaco Ibañez
05/12/2022, 9:10 PMZanie
Paco Ibañez
05/12/2022, 9:20 PM