Ben Ayers-Glassey
03/30/2023, 3:56 PMThe number of mapped children expected to run.
Note that the number of active mapped runs may be less than this if some have not yet entered aThis seems like it would make sense while the flow was still running, but not once it has completed. 🤔state.Pending
1-25 of 3198...i.e. the 3197 mapped runs, plus the parent. So I can't find any mention of the 5 missing expected runs.
Bianca Hoch
03/30/2023, 4:54 PMquery {
task_run(
where: {
flow_run_id: {_eq: "insert_flow_run_id"},
state: {_ne: "Success"}
}
) {
name
id
state
}
}
Success
Ben Ayers-Glassey
03/30/2023, 5:03 PMIn [11]: from prefect.client import Client
...:
...: c = Client()
...:
...: c.graphql("""query {
...: task_run(
...: where: {
...: flow_run_id: {_eq: "45ddf3e0-8d23-460e-a244-28fcb7b96f52"},
...: state: {_neq: "Success"}
...: }
...: ) {
...: name
...: id
...: state
...: }
...: }""")
...:
Out[11]:
{
"data": {
"task_run": [
{
"name": null,
"id": "ebad8ee0-51af-49e3-a519-a53e8b4b1366",
"state": "Mapped"
}
]
}
}
Bianca Hoch
03/30/2023, 5:56 PMBen Ayers-Glassey
03/30/2023, 5:57 PMBianca Hoch
03/30/2023, 5:58 PMBen Ayers-Glassey
03/30/2023, 5:58 PMquery {
mapped_children(task_run_id:"45ddf3e0-8d23-460e-a244-28fcb7b96f52") {
min_start_time
max_end_time
state_counts
}
}
...gives:
{
"data": {
"mapped_children": {
"min_start_time": null,
"max_end_time": null,
"state_counts": {}
}
}
}
🤷