worker.py 文件源码

def requeue(
        self,
        exception=None,
    ):
        task = self.current_task
        exception_traceback = ''.join(traceback.format_stack())

        if not exception:
            exception = WorkerRequeue()

        self._on_requeue(
            task=task,
            exception=exception,
            exception_traceback=exception_traceback,
            args=task['args'],
            kwargs=task['kwargs'],
        )