def cal_dag_dividers()

in dagify/converter/engine.py [0:0]


def cal_dag_dividers(object):
    dag_dividers = []
    for tIdx, task in enumerate(object.uf.get_tasks()):
        td = task.get_attribute(object.dag_divider)
        if td is not None and td not in dag_dividers:
            dag_dividers.append(td)
        task.set_dag_name(td)
    object.dag_dividers = dag_dividers
    return