Terminal state handler Is there any way (or a plan to enable) handling the terminal state of a flow run? i.e. run some custom code on flow run termination and do something with the terminal state. (Prefect v2)

Like including

return_state=True

on the flow call?

Yes for deployed runs (running on

KubernetesJob

)

Adding these hooks is on our roadmap

Right now what I'm trying: 1. Have some task

dummy.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.

You can return a state manually

I'm doing this:

@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)