'Create a dag run for the specified dag.
:param dag_id:
:param run_id:
:param conf:
:param execution_date:
:return:'

def trigger_dag(self, dag_id, run_id=None, conf=None, execution_date=None):

    raise NotImplementedError()
