taskqueue.py 文件源码

def delay(self, *args, **kwargs):
        event = jsonpickle.dumps((self.path, args, kwargs))
        if not self.publish_event:
            logger.error("This task has not yet been registered with a task queue")
            return False

        self.publish_event(event)

        return True