Morning! When I raise a

RETRY

, is it possible to queue an upstream task that had already passed? For example:

drop_glue_database = Parameter()
case(drop_glue_database, True):
    drop_stuff()

save_to_parquet()

If save to parquet fails, I'd like the task to drop and rebuild the database, which is usually unnecessary and parameterized.

This is not possible easily. Either you combine them into a task or you make a subflow for this so that you can re-run it together.

I'll combine them - that seems to be the best path for now. Gracias for the advice