import logging import airflow from airflow import DAG from airflow.operators.python_operator import PythonOperator args = { "owner": "shase", "start_date": airflow.utils.dates.days_ago(2), } def hello(): logging.info("hello world") dag = DAG("hello_dag_1", default_args=args, schedule_interval="0 0 * * *") hello = PythonOperator(task_id="hello", python_callable=hello, dag=dag) hello