code: def __call__(
      self, acd_list: List[AgentConnectorDataType]
  ) -> List[AgentConnectorDataType]:
      ret = acd_list
      for c in self.connectors:
          timer = self.timers[str(c)]
          with timer:
              ret = c(ret)
      return ret
  
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 4 for calling the AgentConnectorPipeline obj's underlying member method code with example usage: obj.__call__(acd_list) and returns: ret