David Stern
08/03/2020, 12:52 AMdbt
, which I think we'll use anyway.Chris White
from datetime import timedelta
@task(max_retries=500, retry_delay=timedelta(minutes=15))
def check_data_available():
# hit the provider to determine whether
# data is available
if data_available:
return None # can optionally return some info
else:
raise RuntimeError("Data not yet available.")
David Stern
08/04/2020, 7:12 AM