code: def fail(self, exception):
          
          fail = failure.create(exception, self._queue, self._payload,
                                self._worker)
          fail.save(self.resq)
          return fail
docs: This method provides a way to fail a job and will use whatever
          failure backend you've provided. The default is the ``RedisBackend``.