code: def use(self, tube):
          
          with self._sock_ctx() as socket:
              if self.current_tube != tube:
                  self.desired_tube = tube
                  self._send_message('use {0}'.format(tube), socket)
                  self._receive_name(socket)
                  self.current_tube = tube
docs: Start producing jobs into the given tube.
  
          :param tube: Name of the tube to USE
  
          Subsequent calls to :func:`put_job` insert jobs into this tube.