def requeue(self, queue=None, retry_count=0):

        if not queue:
            if not self.data or not self.data.get("queue"):
                self.fetch(full_data={"_id": 0, "queue": 1, "path": 1})
            queue = self.data["queue"]

        from .queue import Queue
        queue_obj = Queue(queue)

        self._save_status("queued", updates={
            "queue": queue,
            "retry_count": retry_count
        })

        # Between these two lines, jobs can become "lost" too.

        queue_obj.enqueue_job_ids([str(self.id)])
Requeues the current job. Doesn't interrupt it
dataset/ETHPy150Open pricingassistant/mrq/mrq/job.py/Job.requeue