我想将参数传递到气流DAG中,并在python函数中使用它们。我可以将参数使用到bash操作符中,但是我找不到任何引用来将它们用作python函数。from airflow import DAG
from airflow.operators.bash_operator import BashOperator from airflow.operators.python_operatorimport PythonOperator from airflow.utils.dat
因此,我试图在partial()中使用PostgresOperator方法,但是我得到这个错误显然是因为我无意中将schedule_interval传递给它。我查找了,BasicOperator的分部()方法没有这样的参数,我假设它是所有操作符类的父类。所以我很困惑,我必须把这个参数传递给DAG,但是.partial()没有这样的参数,那么我应该如何创建这个进程和任务呢?我还没有找到任何关于如何实现它的信息。from airflow import DAG
from airflow