code: def remove(self, block_id):
          
          with self._mutex:
              entry = self._block_map[block_id]
              self._queue.remove(entry)
docs: Remove a Processing Block from the queue.
  
          Args:
              block_id (str):