Evan Curtin
07/26/2023, 1:09 PMNate
07/26/2023, 2:31 PMEvan Curtin
07/26/2023, 2:32 PMNate
07/26/2023, 2:37 PMEvan Curtin
07/26/2023, 2:42 PMNate
07/26/2023, 3:00 PMIn [12]: from prefect import get_client
In [13]: async with get_client() as client:
...: user_flow_runs = [r for r in await client.read_flow_runs() if r.created_by.type == "USER"]
...:
In [14]: len(user_flow_runs)
Out[14]: 86
In [15]: user_flow_runs[0].json()
Out[15]: '{stringified JSON you can write to disk / whatever}'
here its just checking that a USER
created the flow run, not a DEPLOYMENT
, but you could further filter on the actual user that created it