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(),