code: def __call__(
      self,
      *,
      rl_module: RLModule,
      data: Optional[Any] = None,
      episodes: List[EpisodeType],
      explore: bool,
      shared_data: Optional[dict] = None,
      **kwargs,
  ):
      # Make sure user does not necessarily send initial input into this pipeline.
      # Might just be empty and to be populated from `episodes`.
      return super().__call__(
          rl_module=rl_module,
          data=data if data is not None else {},
          episodes=episodes,
          explore=explore,
          shared_data=shared_data,
          **kwargs,
      )
  
file_path: ray/rllib/connectors/env_to_module/env_to_module_pipeline.py
imports: from typing import Any, List, Optional
  from ray.rllib.connectors.connector_pipeline_v2 import ConnectorPipelineV2
  from ray.rllib.core.rl_module.rl_module import RLModule
  from ray.rllib.utils.annotations import override
  from ray.rllib.utils.typing import EpisodeType
  from ray.util.annotations import PublicAPI
label_desc: Use image node_id 1 for calling the EnvToModulePipeline obj's underlying member method code with example usage: obj.__call__() and returns: super