Ganesh Kalyansundaram
03/03/2021, 2:54 PMAlex Cano
03/03/2021, 3:09 PMprefect client
to execute the graphql, you can use something like the following:
from prefect.client import Client
from prefect.utilities.graphql import with_args
# Initialize however you need to with any appropriate args
client = Client()
query = {
"query": {
with_args("flow_run", {"where": {"state": {"_eq": "Failed"}}}): {"id": True}
}
}
result = client.graphql(query)
Ganesh Kalyansundaram
03/03/2021, 3:29 PMmutation {
update_flow_run_state(
where: {flow_run_id: {_eq: "5e62f102-b3a9-4d7a-8a1e-bc123c5f467b"}},
_set: {state: "Skipped"}
)
}
Would love some help here too :)mutation {
update_flow_run_state(
where: {flow_run_id: {_eq: "8561e1a2-7caa-4a14-8337-1db23dcca2d4"}},
_set: {state: "Cancelled"}
){
affected_rows
}
}
Got to this, but it isn't working.Jeremiah
03/03/2021, 4:01 PMGanesh Kalyansundaram
03/09/2021, 9:26 AM