特定の時刻に特定のday_of_monthにエアフローを実行するにはどうすればよいですか？

Question

毎月11時に2回目のエアフローを実行しようとしていますが、私はそうしていません。私の設定は次のとおりです。

schedule_interval='00 11 * * *' 

が、私はそれは月単位のために動作させることができていないようです:(：私は毎日のようにDAGを実行したときに

default_args = { 
    'owner': 'airflow', 
    'depends_on_past': False, 
    'start_date': today_date, 
    'email': ['mymail'], 
    'email_on_failure': True, 
    'email_on_retry': True, 
    'retries': 1, 
    'retry_delay': timedelta(minutes=7), 
} 

dag = DAG('my_dag', default_args=default_args, schedule_interval='00 11 02 * *') 

エアフローは完璧に動作します

ありがとう！あなたが言及したコメントで

Answer 1

、あなたがstart_dateためdatetime.today()使用し、それが問題を引き起こしているまさにであること。ジョブ・インスタンスが開始され、Oそれがカバーする期間は終了しましたが、あなたのケースでは決して起こらないでしょう。以下のようなものにstart_dateを調整してみてください。

from datetime import date 
from dateutil.relativedelta import relativedelta 
start_date = date.today() + relativedelta(months=-1) 

私はドキュメントの再読み込みScheduling & Triggersセクションに示唆しています。 DAGを正しくスケジューリングする方法を知るために、私も数時間かかった。