fix dependencies when tasks names are randomized

Author: KonradSchieban

dagify/converter/controlm.py

@@ -58,5 +58,5 @@ def __init__(
         convert(self, "control-m", "TASKTYPE", "JOBNAME")
         cal_dag_dividers(self)
         calc_dag_dependencies(self.uf, "controlm")
-        generate_airflow_dags(self, "JOBNAME_ORIGINAL")
+        generate_airflow_dags(self, "JOBNAME")
 

dagify/converter/uf.py

@@ -96,7 +96,7 @@ def calculate_dag_dependencies_controlm(self):
                     for obj in self.get_tasks():
                         for in_conds in obj.get_in_conditions():
                             if in_conds.get_attribute("NAME") == poutcon.get_attribute("NAME"):
-                                task.add_dependent_task(obj.get_dag_name(), obj.get_attribute("JOBNAME_ORIGINAL"))
+                                task.add_dependent_task(obj.get_dag_name(), obj.get_attribute("JOBNAME"))
         return
 
     def generate_dag_dependencies_by_divider(self, dag_divider, task_name):