Zac Hooper
12/06/2022, 11:35 PM@task
def prod_9e_etl_asx_anns():
logger = get_run_logger()
res = invoke_lambda("prod_9e_etl_asx_anns", {}, True)
<http://logger.info|logger.info>(res)
return ""
@task
def prod_9e_etl_asx_ann_sentiment():
logger = get_run_logger()
res = invoke_lambda("prod_9e_etl_asx_ann_sentiment", {}, True)
<http://logger.info|logger.info>(res)
return ""
@flow(task_runner=SequentialTaskRunner(), retries=2)
def perfom_asx_anns_etl():
x = prod_9e_etl_asx_anns.submit(return_state=True)
y = prod_9e_etl_asx_ann_sentiment.submit(wait_for=[x])
I need to make sure the tasks happen in sequential order. Any idea how I prevent this error?