add taskgroup in xcom_pull

gestaogovbr · May 24, 2024 · ec7f644 · ec7f644
1 parent 99b5be5
commit ec7f644
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/dou_dag_generator.py b/src/dou_dag_generator.py
@@ -319,7 +319,7 @@ def create_dag(self, specs: DAGConfig, config_file: str) -> DAG:
                             },
                         )
                     term_list = (
-                        "{{ ti.xcom_pull(task_ids='select_terms_from_db_"
+                        "{{ ti.xcom_pull(task_ids='exec_searchs.select_terms_from_db_"
                         + str(counter)
                         + "') }}"
                     )