https://prefect.io
Join Slack
Hello. In Prefect 2, I'm using Orion API to read flow runs using `FlowRunFilter`. The problem is tha...
# ask-community
m
Hello. In Prefect 2, I'm using Orion API to read flow runs using 
FlowRunFilter
. The problem is that 
prefect.orion.schemas.filters.FlowRunFilter
requires a parameter of type 
FlowRunFilterState
as 
state
But 
FlowRunFilterState
object doesn't exist in the API reference. There's only 
FlowRunFilterStateType
How can I create such a filter? 
FlowRunFilter(state=FlowRunFilterState(name='COMPLETED'))
(this doesn't work) Thank you
a
we do something like this:
Copy code
flow_runs = await client.read_flow_runs(
    flow_run_filter=FlowRunFilter(
        state=FlowRunFilterState(type=FlowRunFilterStateType(any_=[StateType.RUNNING, StateType.PENDING])),
    ),
    sort=FlowRunSort.EXPECTED_START_TIME_DESC,
    limit=limit,
    offset=offset,
)
m
Thank you. Could you also show how you define the client object and what it is? I was using Client in prefect 1, but I thought it's not there anymore in prefect 2
a
Copy code
from prefect.client import get_client
async with get_client() as client:
.... do stuff....
🙌 1
8 Views
Open in Slack
PreviousNext
Powered by

Prefect Community

Bring 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