hunk.code_window:             hit_horizon = False
               all_done = False
               active_envs.add(env_id)
           # For each agent in the environment
           for agent_id, raw_obs in agent_obs.items():
               policy_id = episode.policy_for(agent_id)
               prep_obs = _get_or_raise(preprocessors,
                                        policy_id).transform(raw_obs)
               if log_once("prep_obs"):
  
hunk.labels: keep keep keep keep replace keep keep keep keep keep
hunk.after_edit:         # For each agent in the environment.
  
hunk.file_path: rllib/evaluation/sampler.py
hunk.type: replace