class_docstr: Parallel rollout runner that allows to collect features by replaying pre-computed action records.
  
  :param max_episode_steps: The maximum number of agent actions to take (careful these are not internal env steps).
  :param deterministic: Deterministic or stochastic action sampling.
  :param action_record_path: Path to action records.
  :param normalization_samples: Number of samples (=steps) to collect normalization statistics.
  :param n_processes: Count of processes to spread the rollout across.
  :param verbose: If True debug messages are printed to the command line.
docstr: Run the parallel rollout in multiple worker processes.
docstr_tok: ["Run","the","parallel","rollout","in","multiple","worker","processes","."]
code: def run_with(
      self,
      env: ConfigType,
      wrappers: CollectionOfConfigType,
      agent: ConfigType,
  ):
      """Run the parallel rollout in multiple worker processes."""
      # initialize observation normalization
      obs_norm_env, agent = ParallelRolloutRunner.init_env_and_agent(
          env_config=env,
          wrappers_config=wrappers,
          max_episode_steps=self.max_episode_steps,
          agent_config=agent,
          input_dir=self.input_dir,
      )
  
      if isinstance(obs_norm_env, ObservationNormalizationWrapper):
          normalization_statistics = obtain_normalization_statistics(
              obs_norm_env, n_samples=self.normalization_samples
          )
          obs_norm_env.set_normalization_statistics(
              normalization_statistics
          )
  
      super().run_with(env=env, wrappers=wrappers, agent=agent)
  
imports: import glob
  import logging
  import os
  import traceback
  from multiprocessing import Queue, Process
  from typing import Iterable
  from omegaconf import DictConfig
  from maze.core.agent.replay_recorded_actions_policy import ReplayRecordedActionsPolicy
  from maze.core.annotations import override
  from maze.core.env.maze_env import MazeEnv
  from maze.core.rollout.parallel_rollout_runner import ParallelRolloutRunner, ParallelRolloutWorker, ExceptionReport
  from maze.core.rollout.rollout_runner import RolloutRunner
  from maze.core.utils.factory import ConfigType, CollectionOfConfigType
  from maze.core.wrappers.observation_normalization.observation_normalization_utils import obtain_normalization_statistics
  from maze.core.wrappers.observation_normalization.observation_normalization_wrapper import ObservationNormalizationWrapper
  from maze.core.wrappers.spaces_recording_wrapper import SpacesRecordingWrapper
  from maze.utils.bcolors import BColors
label_desc: Use image node_id 2 for calling the ActionRecordRolloutRunner obj's underlying member method code with example usage: obj.run_with(env, wrappers, agent) without return types