Zach
01/20/2021, 8:37 PMnicholas
query {
  flow_run(where: { flow_id: { _eq: "<<flow_id>>" }, state: { _eq: "Scheduled" } } ) {
    id
  }
}mutation_contents = ""
for i, id in enumerate(flow_run_ids):
  mutation_contents += f"""
    cancel_{i}: cancel_flow_run(input: { flow_run_id: {id} }) {
      state
    }
  """
mutation = f"""
  mutation {
    {mutation_contents}
  }
"""nicholas
from prefect.client import Client
client = Client()
for id in flow_run_ids:
  client.cancel_flow_run(id)