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.

Prefect Community

Hello all, does an easy way in the graphql api to cancel all submitted, but not currently running flows exist? If so, where in the docs can I read more about this?

Hi <@U01HPF1476W>! I don’t think there is an easy way. You need to fetch them by querying for flow_run_ids with state = Scheduled, then cancel them. Let me try to write the query.

```import requests
import json

query1 = """query {
  flow_run (where: {state: {_eq: "Scheduled"}}){
    	id
    	state
    }
  }
"""

def cancel_mutation(flow_run_id):
    query2 = """
        mutation {
        cancel_flow_run(input: { 
        flow_run_id: \"""" + str(flow_run_id) + """\", 
        }) {
            state
            }
        }
    """
    return query2

url = '<https://api.prefect.io>'
r = <http://requests.post|requests.post>(url, json={'query': query1}, headers={"authorization": "Bearer API_TOKEN"})

print(r.status_code)

data = r.json()['data']
for flow in data['flow_run']:
    flow_id = flow['id']
    _r = <http://requests.post|requests.post>(url, json={'query': cancel_mutation(flow_id)}, headers={"authorization": "Bearer API_TOKEN"})```

Just making sure you know you can do this with
```import prefect
client = prefect.Client()
client.graphql(query)```
and this will authenticate.