yoba-dag.py

from airflow.models import DAG
from airflow.utils.dates import days_ago
from airflow.operators.python import PythonOperator
from airflow.operators.empty import EmptyOperator


def ohai(raz, dva, tri, chetyre):
    print("Оппа нихуя себе", raz, dva)
    print("И так тоже можно:", tri, chetyre)


with DAG(
    dag_id="yoba",
    schedule_interval=None,
    start_date=days_ago(3),
    catchup=False,
) as dag:
    start = EmptyOperator(task_id='start')
    op1 = PythonOperator(
        task_id='bzzz',
        python_callable=ohai,
        op_args=('раз-раз-раз', 'это хардбас'),
        op_kwargs={
            'tri': 'все в спортивках',
            'chetyre': 'адидас',
        },
    )
    end = EmptyOperator(task_id='end')
    start >> op1 >> end

yoba-log.png