在Airflow中,--yes
不是一个可识别的参数。如果你遇到了这个错误,你需要检查你的代码中是否使用了正确的参数。
以下是一个示例解决方法:
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime
def my_task():
# 你的任务逻辑代码
pass
with DAG(
dag_id='my_dag',
start_date=datetime(2021, 1, 1),
schedule_interval='@daily'
) as dag:
task1 = PythonOperator(
task_id='my_task',
python_callable=my_task,
provide_context=True
)
task1
在这个示例中,我们创建了一个名为my_dag
的DAG,并定义了一个名为my_task
的任务。在任务的定义中,我们使用了PythonOperator
来执行一个Python函数my_task
。
要在Airflow中运行这个DAG,你可以使用以下命令:
airflow dags trigger my_dag
请注意,--yes
参数在Airflow中不可用。如果你想在命令行中自动确认任务执行,你可以使用airflow dags trigger
命令,它默认会自动确认任务执行。
希望这个示例能帮助你解决问题!