Chris Arderne
02/13/2023, 6:32 PMChris Arderne
02/13/2023, 6:56 PMChris Arderne
02/13/2023, 7:20 PMZanie
return_state=True
on the flow call?Zanie
Chris Arderne
02/13/2023, 7:26 PMKubernetesJob
)Zanie
Chris Arderne
02/13/2023, 7:28 PMdummy.submit(wait_for=list_of_tasks_I_care_about).wait()
and use the result of that to determine the final state (with some extra logic as Task State != Flow State.
2. As I said above, just call the whole flow from another flow and get it's state.Zanie
Zanie
Chris Arderne
02/13/2023, 7:30 PM@task
def important_task():
return True
@task
def dummy():
return
@task
def insert_state_to_db(state):
...
@flow
def myflow():
a = important_task.submit()
terminal_state = dummy.submit(wait_for=[a]).wait().state.name
insert_state_to_db(terminal_state)
Chris Arderne
02/13/2023, 7:31 PMinsert_state_to_db
to run regardless.Chris Arderne
02/13/2023, 7:31 PM