https://prefect.io logo
Title
j

Jason

05/13/2022, 3:05 PM
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.
k

Kevin Kho

05/13/2022, 3:08 PM
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.
j

Jason

05/13/2022, 3:15 PM
I'll combine them - that seems to be the best path for now. Gracias for the advice