hunk.code_window:             else:
                   del active_episodes[env_id]
                   resetted_obs: Dict[AgentID, EnvObsType] = base_env.try_reset(
                       env_id)
               # Reset not supported, drop this env from the ready list.
               if resetted_obs is None:
                   if horizon != float("inf"):
                       raise ValueError(
  
hunk.labels: keep keep replace keep keep keep keep keep
hunk.after_edit:                 resetted_obs: Dict[EnvID, Dict[AgentID, EnvObsType]] = \
                       base_env.try_reset(
  
hunk.file_path: rllib/evaluation/sampler.py
hunk.type: replace
file: package io.ray.serve;
  
  import io.ray.serve.generated.EndpointInfo;
  import io.ray.serve.generated.EndpointSet;
  import java.util.Map;
  
  public class DummyServeController implements ServeController {
  
    private Map<String, EndpointInfo> endpoints;
  
    @Override
    public byte[] getAllEndpoints() {
      EndpointSet.Builder builder = EndpointSet.newBuilder();
      builder.putAllEndpoints(endpoints);
      return builder.build().toByteArray();
    }
  
    public void setEndpoints(Map<String, EndpointInfo> endpoints) {
      this.endpoints = endpoints;
    }
  }
  