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)