Jason
05/13/2022, 3:05 PMRETRY
, 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.Kevin Kho
05/13/2022, 3:08 PMJason
05/13/2022, 3:15 PM