From 42799b399804f0da62a9a9203c799515ca55303e Mon Sep 17 00:00:00 2001
From: David Betancur <dbetancur@psc.edu>
Date: Mon, 6 Feb 2023 10:14:13 -0500
Subject: [PATCH] Bugfix missing parameter on FlexMultiDagRunOperator call

---
 src/ingest-pipeline/airflow/dags/launch_multi_analysis.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/ingest-pipeline/airflow/dags/launch_multi_analysis.py b/src/ingest-pipeline/airflow/dags/launch_multi_analysis.py
index 50b5af9d..e21ac535 100644
--- 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(),