Jason05/13/2022, 3:05 PM
, is it possible to queue an upstream task that had already passed? For example:
If save to parquet fails, I'd like the task to drop and rebuild the database, which is usually unnecessary and parameterized.
drop_glue_database = Parameter() case(drop_glue_database, True): drop_stuff() save_to_parquet()
Kevin Kho05/13/2022, 3:08 PM
Jason05/13/2022, 3:15 PM