Anat Tal Gagnon
08/30/2022, 1:39 PMNate
08/30/2022, 1:41 PMprefect agent start -q myqueue
then in your prefect deployment build
command you'd want to pass -q myqueue
as wellAnat Tal Gagnon
08/30/2022, 1:49 PMNate
08/30/2022, 1:55 PMcreate_flow_run_from_deployment
by deployment_id
from prefect.client import get_client
from prefect.utilities.asyncutils import sync_compatible
@sync_compatible
async def trigger_flow_run(deployment_id: str, params: dict) -> FlowRun:
async with get_client() as client:
return await client.create_flow_run_from_deployment(
deployment_id=deployment_id, parameters=params
)
Anat Tal Gagnon
08/30/2022, 1:57 PMNate
08/30/2022, 2:01 PMAnat Tal Gagnon
08/30/2022, 2:04 PMNate
08/30/2022, 2:11 PMAnat Tal Gagnon
08/30/2022, 2:12 PMNate
08/30/2022, 6:31 PMbuild
your deployment?Anat Tal Gagnon
08/30/2022, 6:32 PMNate
08/30/2022, 6:35 PMAnat Tal Gagnon
08/30/2022, 6:40 PMNate
08/30/2022, 7:35 PMArnas
10/24/2022, 10:32 PM