Gerti
flow_runs = await client.read_flow_runs( flow_run_filter=FlowRunFilter(state={"type": {"any_": [StateType.RUNNING]}}), name_filter=FlowRunFilterName(id={"like_": "product"}) )
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.