Airflow DAG를 예약하려고하는데 성공적으로 예약 할 수 없습니다. 유효한 시작일이 있습니다. 매일 오전 5시 30 분에 실행되도록 예약하고 싶지만 지난 며칠 동안 수동으로 트리거해야했습니다.
내 일정 간격은 다음과 같습니다 schedule_interval='30 5 0 0 0'.. 나는 또한 다음과 같은 다른 구문으로 시도했지만 schedule_interval='30 5 * * *'작동하지 못했습니다. 아래는 내 완전한 코드입니다.
default_dag_args = {
'start_date': datetime.datetime(2020, 9, 15),
}
with models.DAG(
'data_dump',
schedule_interval='30 5 0 0 0',
default_args=default_dag_args) as dag:
hello = bash_operator.BashOperator(
task_id='hello',
bash_command='echo Hello.')
goodbye_bash = bash_operator.BashOperator(
task_id='bye',
bash_command='echo Goodbye.')
hello >> goodbye_bash
나는 schedule_interval시간대와 관련이 있는지 궁금해하기 시작했습니다 . 현재 저는 .NET에서 설정된 Cloud Composer 환경에서 Airflow를 사용하고 europe-west1-b있습니다.
내 코드의 문제점을 파악하고 DAG를 올바르게 예약하는 방법을 파악하는 데 도움이 필요하며 응답 해 주시면 감사하겠습니다. 미리 감사드립니다.
@ philipp-johannis가 정확 30 5 * * *하고 정확합니다 scheduler_interval.
start_date다음과 같이 이전 버전 으로 테스트 할 수 있습니다 .
with models.DAG(
'data_dump',
schedule_interval='30 5 0 0 0',
start_date=datetime.datetime(2020, 9, 1)) as dag:
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다