Sophia Ponte
02/27/2024, 12:07 AMMarvin
02/27/2024, 12:07 AMNate
02/27/2024, 12:10 AMfrom prefect import get_client
async with get_client() as client:
runs = await client.read_task_runs(TaskRunFilter(parent_flow_run_id=dict(any_=[UUID(..), ...])))
Nate
02/27/2024, 12:10 AMfrom prefect.client.schemas.filters import FlowRunFilter, TaskRunFilter
Nate
02/27/2024, 12:10 AMSophia Ponte
02/28/2024, 12:11 AMBring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by