Воздушный поток с использованием Cronitier

Я пытаюсь использовать Cronitier, чтобы запланировать задание, которое будет выполняться ежемесячно каждые 2 вторника. Я пробовал ниже Это мой частичный сценарий.

из croniter импорт croniter

cron = croniter (00 21 * * 2 # 2)

dag = DAG (‘recurring_job’, catchup = False, default_args = default_args, schedule_interval = cron) Но это не сработало. Не могли бы вы помочь мне или дайте ссылку.

Не могли бы вы предоставить сообщение об ошибке?   —  person Murali Krishna    schedule 18.11.2020

См. также:  Как проверить dag воздушного потока в unittest?
Понравилась статья? Поделиться с друзьями:
IT Шеф
Комментарии: 2
  1. Murali Krishna

    Вы можете просто указать строку cron напрямую:

    dag = DAG('recurring_job', schedule_interval="00 21 * * 2#2")
    
    

    Airflow переведет это с помощью croniter внутри.

Добавить комментарий

;-) :| :x :twisted: :smile: :shock: :sad: :roll: :razz: :oops: :o :mrgreen: :lol: :idea: :grin: :evil: :cry: :cool: :arrow: :???: :?: :!: