Brad
05/05/2020, 2:14 AMJeremiah
05/05/2020, 3:48 AMquery {
task_run(limit: 1) {
task {
upstream_edges(limit: 3) {
upstream_task{
id
name
}
}
}
}
}
upstream_edges
or downstream_edges
and, for each edge, the corresponding upstream_task
or downstream_task
.Brad
05/05/2020, 3:56 AMJeremiah
05/05/2020, 3:58 AMquery {
task_run(limit: 1, where: {flow_run_id: {_eq: XYZ}} ) {
task {
upstream_edges(limit: 3) {
upstream_task{
task_runs(where: {flow_run_id: {_eq: XYZ}}) {
state
id
}
}
}
}
}
}
Brad
05/05/2020, 4:00 AMJeremiah
05/05/2020, 4:00 AMBrad
05/05/2020, 4:02 AMJeremiah
05/05/2020, 4:02 AMBrad
05/05/2020, 4:20 AM