hunk.code_window:                         self._obs_space, observation)
               except AttributeError:
                   raise ValueError(
                       "Observation for a Box space should be an np.array, "
                       "not a Python list.", observation)
           self._i += 1
       @property
       @PublicAPI
       def size(self):
  
hunk.labels: keep keep keep replace replace keep keep keep keep keep
hunk.after_edit:                     "Observation for a Box/MultiBinary/MultiDiscrete space "
                       "should be an np.array, not a Python list.", observation)
  
hunk.file_path: python/ray/rllib/models/preprocessors.py
hunk.type: replace
file: from __future__ import absolute_import
  from __future__ import division
  from __future__ import print_function
  
  import getpass
  import os
  
  
  def get_ssh_user():
      """Returns ssh username for connecting to cluster workers."""
  
      return getpass.getuser()
  
  
  def get_ssh_key():
      """Returns ssh key to connecting to cluster workers.
  
      If the env var TUNE_CLUSTER_SSH_KEY is provided, then this key
      will be used for syncing across different nodes.
      """
      path = os.environ.get("TUNE_CLUSTER_SSH_KEY",
                            os.path.expanduser("~/ray_bootstrap_key.pem"))
      if os.path.exists(path):
          return path
      return None
  