Airflow DAG の Hello World

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