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(exp_bytes: bytes) → Dict

Process a batch of experiences.

参数:

exp_bytes (bytes) -- Serialized 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