code: 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"]
  
          self._save_status("queued", updates={
              "queue": queue,
              "datequeued": datetime.datetime.utcnow(),
              "retry_count": retry_count
          })
docs: Requeues the current job. Doesn't interrupt it