Bugfix missing parameter on FlexMultiDagRunOperator call

hubmapconsortium · Feb 6, 2023 · 42799b3 · 42799b3
1 parent 1ac78fd
commit 42799b3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/ingest-pipeline/airflow/dags/launch_multi_analysis.py b/src/ingest-pipeline/airflow/dags/launch_multi_analysis.py
@@ -176,6 +176,7 @@ def flex_maybe_spawn(**kwargs):
         task_id='flex_maybe_spawn',
         dag=dag,
         trigger_dag_id='launch_multi_analysis',
+        python_callable=flex_maybe_spawn,
         op_kwargs={
             'crypt_auth_tok': utils.encrypt_tok(airflow_conf.as_dict()
                                                 ['connections']['APP_CLIENT_SECRET']).decode(),