trinity.buffer.pipelines.experience_pipeline module

trinity.buffer.pipelines.experience_pipeline.get_input_buffers(pipeline_config: ExperiencePipelineConfig, buffer_config: BufferConfig) → Dict[source]

Get input buffers for the experience pipeline.

class trinity.buffer.pipelines.experience_pipeline.ExperiencePipeline(config: Config)[source]

Bases: object

A class to process experiences.

__init__(config: Config)[source]
async prepare() → None[source]
async process(exps: List[Experience]) → Dict[source]

Process a batch of experiences.

Parameters:

exps (List[Experience]) – List of experiences to process. These experiences are typically generated by an explorer in one step.

Returns:

A dictionary containing metrics collected during the processing of experiences.

Return type:

Dict

async close() → None[source]