Stefan
07/10/2022, 10:42 AMAnna Geller
07/10/2022, 12:06 PMStefan
07/10/2022, 12:09 PMAnna Geller
07/10/2022, 12:13 PMimport asyncio
from prefect.client import get_client
from prefect import flow, task, get_run_logger
@task
async def child_flow():
async with get_client() as client:
depl_id = "71334806-93ff-4bdc-ba98-fde1f97d5622"
response = await client.create_flow_run_from_deployment(
depl_id, parameters=dict()
)
logger = get_run_logger()
<http://logger.info|logger.info>(response)
@flow
async def parent_flow():
await child_flow()
if __name__ == "__main__":
asyncio.run(parent_flow())
or if you run it from some application:
import asyncio
from prefect.client import get_client
async def main():
async with get_client() as client:
depl_id = "074db2e5-229a-460e-85ad-fca31b379fd2"
response = await client.create_flow_run_from_deployment(
depl_id, parameters=dict()
)
print(response)
if __name__ == "__main__":
asyncio.run(main())
the UI integration for parametrized ad hoc runs is on the roadmapStefan
07/10/2022, 12:25 PMAnna Geller
07/10/2022, 12:49 PMStefan
07/10/2022, 12:50 PMAnna Geller
07/10/2022, 12:50 PMStefan
07/10/2022, 7:57 PMAnna Geller
07/10/2022, 10:08 PMStefan
07/11/2022, 1:33 PMAnna Geller
07/11/2022, 7:44 PM