Я пытаюсь создать DAG
, который запускается при каждом развертывании кода моего приложения (DAG
s). Я попытался присвоить start_date
на данный момент и schedule_interval
на один раз, надеясь, что он будет запускаться каждый раз при создании DAG (надеюсь, при каждом развертывании):
dag_args = {
'owner': 'airflow',
'start_date': datetime.now(),
'retries': 1,
'email_on_retry': False,
'catchup': True
}
Но это не помогает что я буду sh. (Пробовал также chatchup=False
)
Есть идеи \ предложения? (Я стараюсь не вызывать его извне)
Спасибо,