AirFlowException - Python_Callable 必须是可调用的

Question

我对现有工作流程做了一个小改动，但它破坏了气流。这是代码：

dag_name = platform + "_" + report['table']

dag = DAG(
    dag_name,
    catchup=True,
    default_args=default_args,
    schedule_interval=report['schedule']
)

with dag:

    trigger_report = PythonOperator(
        task_id=dag.dag_id + '_trigger_report',
        python_callable=trigger_report,
        provide_context=True,
        op_kwargs={
            'report_name': report['report'],
            'amazonmws_conn_id': default_args['amazonmws_conn_id']
        },
        dag=dag
    )

这是我收到的错误：

airflow.exceptions.AirflowException: python_callable param must be callable

Answer 1

对于收到此消息的其他人来说，错误是由于任务和 python_callable 函数具有相同的名称造成的。

Answer 2

似乎您正在将trigger_report自己传递为python_callable.

这是故意的吗？它已经有价值了吗？
（可能，否则你会得到一个NameError: name 'trigger_report' is not defined）