airflow/models/taskinstance.py
def error(self, session=None):
        """
        Forces the task instance's state to FAILED in the database.
        """
        self.log.error("Recording the task instance as FAILED")
        self.state = State.FAILED
        session.merge(self)
        session.commit()
def error(self, session=None):
        """
        Forces the task instance's state to FAILED in the database.
        """
        self.log.error("Recording the task instance as FAILED")
        self.state = State.FAILED
        session.merge(self)
        session.commit()
def error ( self , session = None ) : self . log . error ( "Recording the task instance as FAILED" ) self . state = State . FAILED session . merge ( self ) session . commit ( )
Forces the task instance's state to FAILED in the database.
Forces the task instance s state to FAILED in the database .