"""
        Return the DagRun for this TaskInstance.
        :param session: SQLAlchemy ORM Session
        TODO: make it works for AIP-44
        :return: Pydantic serialized version of DaGrun
        """
        raise NotImplementedError()
    def _execute_task(self, context, task_orig):
        """
        Execute Task (optionally with a Timeout) and push Xcom results.
        :param context: Jinja2 context
        :param task_orig: origin task
        """
        from airflow.models.taskinstance import _execute_task
        return _execute_task(task_instance=self, context=context, task_orig=task_orig)
    @provide_session
    def refresh_from_db(self, session: Session = NEW_SESSION, lock_for_update: bool = False) -> None:
        """
        Refresh the task instance from the database based on the primary key.
        :param session: SQLAlchemy ORM Session
        :param lock_for_update: if True, indicates that the database should
            lock the TaskInstance (issuing a FOR UPDATE clause) until the
            session is committed.
        """
        from airflow.models.taskinstance import _refresh_from_db
        _refresh_from_db(task_instance=self, session=session, lock_for_update=lock_for_update)
    def set_duration(self) -> None: