from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta

schedule_interval = '0 */30 * * *'

default_args = {
    'owner': 'mvsyomo1',
    'start_date': datetime(2017, 5, 3, 8, 30),
    'email': ['mvsyomo1@mts.ru']
}

dag = DAG('test',
          catchup=False,
          schedule_interval=schedule_interval,
          concurrency=1,
          default_args=default_args)

with dag as dag:
    task1 = BashOperator(task_id='just_test',
                         bash_command="sleep 60 && echo iddqd")