Hi, Can anyone help with making a GraphQL call to start a flow (create a flow run) and get the id of the flow run back (so I can monitor the state)?

from prefect.utilities.graphql import EnumValue, with_args *class FlowExcept*(Exception): pass

*def create_prefect_flow*(prefect_client, name, parameters=None, run_name=None, project=None, version=None):

where_clause = { "_and": { "name": {"_eq": name}, "version": {"_eq": version}, "project": {"name": {"_eq": project}}, } } query = { "query": { with_args( "flow", { "where": where_clause, "order_by": { "name": EnumValue("asc"), "version": EnumValue("desc"), }, "distinct_on": EnumValue("name"), }, ): {"id": True} } } result = prefect_client.graphql(query)

if

*not* result.data.flow:

*raise* FlowExcept(f"flow name {name} not found")

flow_id = result.data.flow[0].

id

*return* flow_id, prefect_client.create_flow_run(flow_id=flow_id,

run_name=run_name, parameters=parameters)

Hey @Thomas Hoeck, like Rob is suggesting, you can use

prefect.client.client.Client.create_flow_run

. It will return the ID.

prefect.tasks.prefect.flow_run.StartFlowRun.run

also returns the ID if wait=False. If wait=True, you would need to write some extra code to get the ID

I was intending to start the flow from MatLab (don't ask why) and therefor want to construct the needed mutation and query 🙂 @Kevin Kho

This would be the simple request without Prefect

import requests
import json
query = """mutation {
  create_flow_run(input: { 
  flow_id: "5ac80adc-442a-4e53-bc01-d9d65bffd6aa"}) {
    id
  }
}"""
url = '<https://api.prefect.io>'
r = <http://requests.post|requests.post>(url, json={'query': query}, headers={"authorization": "Bearer insert_token"})
print(r.status_code)
print(r.text)

Wonderfull! Thank you! @Kevin Kho