'Returns a list of dag run execution dates currently running
:param session:
:return: List of execution dates'

@provide_session
def get_active_runs(self, session=None):

    runs = DagRun.find(dag_id=self.dag_id, state=State.RUNNING)
    active_dates = []
    for run in runs:
        active_dates.append(run.execution_date)
    return active_dates
