trinity.buffer.schema package# Submodules# trinity.buffer.schema.formatter module ExperienceFormatter ExperienceFormatter.format() TaskFormatter TaskFormatter.__init__() TaskFormatter.format() SFTFormatter SFTFormatter.__init__() SFTFormatter.format() DPOFormatter DPOFormatter.__init__() DPOFormatter.format() trinity.buffer.schema.sql_schema module TaskModel TaskModel.id TaskModel.raw_task TaskModel.from_dict() ExperienceModel ExperienceModel.id ExperienceModel.timestamp ExperienceModel.task_id ExperienceModel.run_id ExperienceModel.msg_id ExperienceModel.model_version ExperienceModel.reward ExperienceModel.consumed ExperienceModel.to_experience() ExperienceModel.from_experience() BlobModel BlobModel.id BlobModel.experience_bytes SFTDataModel SFTDataModel.id SFTDataModel.message_list SFTDataModel.to_experience() SFTDataModel.from_experience() DPODataModel DPODataModel.id DPODataModel.chosen_message_list DPODataModel.rejected_message_list DPODataModel.to_experience() DPODataModel.from_experience() init_async_engine() Module contents# async trinity.buffer.schema.init_async_engine(db_url: str, table_name: str, schema_type: str | None) → Tuple[source]# Create an async SQLAlchemy engine and table classes. Returns: (async_engine, table_cls) For experience/sft/dpo schema: (async_engine, meta_cls, blob_cls) Return type: For task schema
