• Share this text:
Airflow Text Checked by guest on 14th January 2020 03:31:37 PM

from __future__ import print_function

import airflow

from airflow import DAG

from airflow.operators.bash_operator import BashOperator

from datetime import timedelta


args = {

    'owner': 'abc',

    'start_date': airflow.utils.dates.days_ago(1),

    'provide_context': True,

    'depends_on_past': False

}


with DAG('custom_dag', schedule_interval='0 14 * * *', default_args=args) as dag:

    task1 = BashOperator(

        task_id='custom_dag_task',

        bash_command='set e; python3 dir/main.py',

    )



Report Abuse

Login or Register to edit or copy and save this text. It's free.