trinity.buffer.pipelines.experience_pipeline module

目录

trinity.buffer.pipelines.experience_pipeline module#

trinity.buffer.pipelines.experience_pipeline.get_input_buffers(pipeline_config: ExperiencePipelineConfig) → Dict[源代码]#: Get input buffers for the experience pipeline.

class trinity.buffer.pipelines.experience_pipeline.ExperiencePipeline(config: Config)[源代码]#

基类：object

A class to process experiences.

__init__(config: Config)[源代码]#

async prepare() → None[源代码]#

async process(exps: List[Experience]) → Dict[源代码]#

Process a batch of experiences.

参数:: exps (List[Experience]) -- List of experiences to process. These experiences are typically generated by an explorer in one step.
返回:: A dictionary containing metrics collected during the processing of experiences.
返回类型:: Dict

async close() → None[源代码]#