使用Airflow 2 Taskflow API定义DAG时出现问题

pip install apache-airflow[taskflow]

from airflow.decorators import dag, task
from airflow.utils.dates import days_ago

@dag(default_args=default_args, schedule_interval='@daily', start_date=days_ago(1))
def my_dag():
    @task
    def my_task():
        print("Hello, Taskflow API!")

my_dag()

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}

airflow --version