base.py 文件源码

def after_return(self, status, retval, task_id, args, kwargs, einfo):
        """
        Ensures that any database session opened by the Task is closed.
        :param status: Current task state.
        :param retval: Task return value/exception.
        :param task_id: Unique id of the task.
        :param args: Original arguments for the task that returned.
        :param kwargs: Original keyword arguments for the task that returned.
        :param einfo: ExceptionInfo instance, containing the traceback (if any).
        :return: None
        """
        super(DatabaseTask, self).after_return(status, retval, task_id, args, kwargs, einfo)