ek
from prefect import Client api_server="<http://prefect-server-apollo:4200>" tenant_id="XXXX" flow_id="XXXX" client = Client(api_server=api_server,tenant_id=tenant_id) flow_run = client.create_flow_run( flow_id=flow_id, parameters={"KEY": "VALUE"} ) print(flow_run) flow_status = client.get_flow_run_state(flow_run) print(flow_status)
flow_id
Anna Geller
query { flow ( where: {project_id: {_eq: "PROJECT_ID"}} order_by: {version: desc}, limit: 1 ) { id name version created } }
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.