Sample Dag with Bash Operator.

simple_bash_dag.py

#!/usr/bin/python3
from airflow.models import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta

# let's setup arguments for our dag

my_dag_id = "my_first_dag"

default_args = {
    'owner': 'proton',
    'depends_on_past': False,
    'retries': 10,
    'concurrency': 1
}

# dag declaration

dag = DAG(
    dag_id=my_dag_id,
    default_args=default_args,
    start_date=datetime(2019, 6, 17),
    schedule_interval=timedelta(seconds=5)
)


# Here's a task based on Bash Operator!

bash_task = BashOperator(task_id='bash_task_1',
                         bash_command="echo 'Hello Airflow!'",
                         dag=dag)

simple_python_dag.py

from airflow.models import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta


my_dag_id = "my_first_dag"

default_args = {
    'owner': 'proton',
    'depends_on_past': False,
    'retries': 10,
    'concurrency': 1
}

def hello():
    print("Hello Airflow Using a Python Operator!")

dag = DAG(
    dag_id=my_dag_id,
    default_args=default_args,
    start_date=datetime(2019, 6, 17),
    schedule_interval=timedelta(minutes=5)
)

python_task = PythonOperator(task_id='python-task',
                             python_callable=hello,
                             dag=dag)

simple_python_dag_kwargs.py

from airflow.models import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta

my_dag_id = "my_first_python_dag_with_kwargs"

default_args = {
    'owner': 'proton',
    'depends_on_past': False,
    'retries': 10,
    'concurrency': 1
}

def my_args(*args,**kwargs):
    print("My Args are {}".format(args))
    print("My Kwargs are {}".format(kwargs))

dag = DAG(
    dag_id=my_dag_id,
    default_args=default_args,
    start_date=datetime(2019, 6, 17),
    schedule_interval=timedelta(seconds=5)
)

python_task = PythonOperator(task_id='python-task',
                             python_callable=my_args,
                             op_args={'a','b','c'},
                             op_kwargs={'a':'2'},
                             dag=dag)

simple_python_dag_with_args.py

from airflow.models import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta

my_dag_id = "my_first_python_dag_with_args"

default_args = {
    'owner': 'proton',
    'depends_on_past': False,
    'retries': 10,
    'concurrency': 1
}

def my_args(*args):
    print("My Args are {}".format(args))

dag = DAG(
    dag_id=my_dag_id,
    default_args=default_args,
    start_date=datetime(2019, 6, 17),
    schedule_interval=timedelta(seconds=5)
)

python_task = PythonOperator(task_id='python-task',
                             python_callable=my_args,
                             op_args={'a','b','c'},
                             dag=dag)