ObservationAggregator

class maze.train.parallelization.observation_aggregator.ObservationAggregator

Observation aggregator used in distributed training for aggregating observations of multiple instances of the same environment.

abstract aggregate() → Any

This function aggregates the collected list of observations.

reset(observations: List[Any] = None) → None

Reset aggregator.

Parameters

observations – a list of observations.