Found it: async def monitor_realtime_sync(): start_time = datetime.now() - timedelta(minutes=43800) async with get_client() as client: r = await client.read_flow_runs( flow_filter=FlowFilter(name={“any_“: [“sync_snowflake_realtime”]}), limit=5, flow_run_filter=FlowRunFilter( state=FlowRunFilterState( type=FlowRunFilterStateName(any_=[“COMPLETED”]) ), start_time=FlowRunFilterStartTime( after_=start_time ) )) for flow in r: print(flow.name, flow.flow_id, flow.created)