AirFlowException - Python_Callable должен быть вызываемым - PullRequest
Новая
       25

AirFlowException - Python_Callable должен быть вызываемым

0 голосов
/ 16 июня 2019

Я внес небольшое изменение в существующий рабочий процесс, и он нарушил воздушный поток.Вот код: 

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

1 Ответ

0 голосов
/ 16 июня 2019

похоже, что вы передаете trigger_report сам как python_callable.

Это намеренно? у него уже есть значение?
(возможно, в противном случае вы бы получили NameError: name 'trigger_report' is not defined)

...