Konstantinos
10/07/2020, 6:18 PMjosh
10/07/2020, 6:34 PMdef notif(tracked_obj, old_state, new_state):
if new_state.is_successful():
print(new_state.result)
return new_state
@task(state_handlers=[notif])
def a():
return 1234
@task
def b(x):
print(x)
with Flow("test") as flow:
a = a()
b = b(a)
This essentially is saying instead of looking at the inputs of the downstream look at the result of the upstream (which are the inputs to the downstream)Konstantinos
10/08/2020, 7:38 AM