Zach
01/20/2021, 8:37 PMnicholas
query {
flow_run(where: { flow_id: { _eq: "<<flow_id>>" }, state: { _eq: "Scheduled" } } ) {
id
}
}
and then map over that list something like this:
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}
}
"""
from prefect.client import Client
client = Client()
for id in flow_run_ids:
client.cancel_flow_run(id)