Wie, um korrekt zu arbeiten Luftstrom schedule_interval

Möchte ich versuchen, den Luftstrom anstelle von Cron.
Aber schedule_interval nicht funktioniert, als ich erwartet hatte.

Schrieb ich den python-code wie unten gezeigt.
Und in meinem Verständnis, Airflow haben sollte, lief auf "2016/03/30 8:15:00" aber es hat nicht funktioniert damals.

Wenn ich es geändert wie hier "'schedule_interval': timedelta(minutes = 5)", wird es richtig geklappt hat, denke ich.

"Notice_slack.sh" nur zu nennen, slack-api, um meine channels.

# -*- coding: utf-8 -*-
from __future__ import absolute_import, unicode_literals
import os
from airflow.operators import BashOperator
from airflow.models import DAG
from datetime import datetime, timedelta

args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2016, 3, 29, 8, 15),
}

dag = DAG(
    dag_id='notice_slack',
    default_args=args,
    schedule_interval="@daily",
    dagrun_timeout=timedelta(minutes=1))

# cmd file name
CMD = '/tmp/notice_slack.sh'

run_this = BashOperator(
    task_id='run_transport', bash_command=CMD, dag=dag)

Möchte ich laufen einige meiner Scripte zu einer bestimmten Zeit jeden Tag, wie dieser cron-Einstellung.

15 08 * * * bash /tmp/notice_slack.sh

Ich habe das Dokument gelesen Planung & Trigger, und ich weiß, es ist ein bisschen anders cron.
Also ich Versuch zu ordnen unter "Startdatum" und "schedule_interval" Einstellungen.

Weiß jemand, was soll ich tun ?

Luftstrom version

INFO - Mit executor LocalExecutor

v1.7.0

amazon linux-ami/2015.09-release-notes

InformationsquelleAutor k16 | 2016-03-30

Schreibe einen Kommentar