code: def retry(self, queue=None, delay=None, max_retries=None):
          
  
          max_retries = max_retries
          if max_retries is None:
              max_retries = self.max_retries
  
          if self.data.get("retry_count", 0) >= max_retries:
              raise MaxRetriesInterrupt()
  
          exc = RetryInterrupt()
  
          exc.queue = queue or self.queue or self.data.get("queue") or "default"
          exc.retry_count = self.data.get("retry_count", 0) + 1
          exc.delay = delay
          if exc.delay is None:
              exc.delay = self.retry_delay
  
          self._attach_original_exception(exc)
  
          raise exc
docs: Marks the current job as needing to be retried. Interrupts it.