Philip MacMenamin
11/17/2020, 9:23 PMJenny
11/17/2020, 9:37 PMPhilip MacMenamin
11/17/2020, 9:39 PM@task(name="a")
def add_one(x):
return x + 1
with Flow("Add One") as flow:
a = add_one(1)
I'd like to be able to ask what Task a's final state is, eg if it's successful, or not.Jenny
11/17/2020, 9:52 PMPhilip MacMenamin
11/17/2020, 10:02 PMJenny
11/17/2020, 10:08 PM[2020-11-17 17:06:25-0500] INFO - prefect.FlowRunner | Beginning Flow run for 'simple-map'
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'c': Starting task run...
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'c': Finished task run for task with final state: 'Success'
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'return_list': Starting task run...
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'return_list': Finished task run for task with final state: 'Success'
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'mapped_task': Starting task run...
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'mapped_task': Finished task run for task with final state: 'Mapped'
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'mapped_task[0]': Starting task run...
[2020-11-17 17:06:25-0500] INFO - prefect.mapped_task[0] | 1
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'mapped_task[0]': Finished task run for task with final state: 'Success'
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'mapped_task[1]': Starting task run...
[2020-11-17 17:06:25-0500] INFO - prefect.mapped_task[1] | 2
[2020-11-17 17:06:25-0500] INFO - prefect.TaskRunner | Task 'mapped_task[1]': Finished task run for task with final state: 'Success'
[2020-11-17 17:06:25-0500] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded
query {
task_run (where: {task: {name: {_eq: "a"}}}) {
state
}
}
query {
flow_run (where: {flow: {name: {_eq: "Add One"}}}) {
task_runs (where: {task: {name: {_eq: "a"}}}) {
state
name
}
}
}
Philip MacMenamin
11/17/2020, 10:24 PMwith Flow("example") as flow:
a = add_one(1)
b = task_2(2, task_args=dict(name="b"))
if a.is_successful and b.is_successful:
do_something(b)
flow_run_id
and take some action. I want a way to notify some external entity that a run has completed, and it's succeeded or failed.Jenny
11/17/2020, 10:51 PMPhilip MacMenamin
11/17/2020, 11:39 PM