Jason Motley
01/24/2022, 6:11 PMKevin Kho
Jason Motley
01/24/2022, 6:15 PMKevin Kho
Jason Motley
01/24/2022, 6:18 PM@task(name = "Extract", log_stdout=True, checkpoint=False, max_retries=3, retry_delay=timedelta(seconds=10))
def extract(connection: any, start_date: str) -> any:
df=pd.read_sql_query(f"""
select bla bla
""", con=connection)
return df
Kevin Kho
connection
is somehow not working to begin with. If you’d like to test if retries do anything, you can try adding logging to a broken piece of code.Jason Motley
01/24/2022, 6:22 PMKevin Kho
Jason Motley
01/24/2022, 6:24 PMKevin Kho
Jason Motley
01/24/2022, 6:27 PM