docs: def bury_job(self, job_id, pri=65536):
          """Mark the given job_id as buried. The job must have been previously reserved by this connection
  
          :param job_id: Job to bury
          :param pri: Priority for the newly-buried job. If not passed, will keep its current priority
          :type pri: int
          """
          if hasattr(job_id, 'job_id'):
              job_id = job_id.job_id
          with self._sock_ctx() as socket:
              self._send_message('bury {0} {1}'.format(job_id, pri), socket)
              return self._receive_word(socket, b'BURIED')