code: def reset(self, env_id: str):
      for c in self.connectors:
          c.reset(env_id)
  
file_path: ray/rllib/connectors/agent/pipeline.py
imports: import logging
  from typing import Any, List
  from collections import defaultdict
  from ray.rllib.connectors.connector import AgentConnector, Connector, ConnectorContext, ConnectorPipeline
  from ray.rllib.connectors.registry import get_connector, register_connector
  from ray.rllib.utils.typing import ActionConnectorDataType, AgentConnectorDataType
  from ray.util.annotations import PublicAPI
  from ray.util.timer import _Timer
label_desc: Use image node_id 2 for calling the AgentConnectorPipeline obj's underlying member method code with example usage: obj.reset(env_id) without return types