@provide_session<EOL><INDENT>def get_dagrun(self, session):<DEDENT>
from airflow.models.dagrun import DagRun  <EOL>dr = session.query(DagRun).filter(<EOL>DagRun.dag_id == self.dag_id,<EOL>DagRun.execution_date == self.execution_date<EOL>).first()<EOL>return dr<EOL>
Returns the DagRun for this TaskInstance

:param session:
:return: DagRun