xplogger.experiment_manager.store package

Submodules

xplogger.experiment_manager.store.mongo module

Class to interface with the mongodb store.

class xplogger.experiment_manager.store.mongo.MongoStore(config: Dict[str, Any])

Bases: object

delete_records(record_list: xplogger.experiment_manager.record.record_list.RecordList, delete_from_filesystem: bool = False) → None

Delete records from the db and filesystem (optional).

Parameters

• record_list (RecordList) –

• delete_from_filesystem (bool, optional) – should delete records from the filesystem. Defaults to False.

get_records(query) → xplogger.experiment_manager.record.record_list.RecordList

Get records from the db.

get_unanalyzed_records() → xplogger.experiment_manager.record.record_list.RecordList

Get a list of un-analyzed records.

ignore_records_by_status(status: str) → xplogger.experiment_manager.record.record_list.RecordList

Get a list of records which do not match the status.

load_from_file(filepath: pathlib.Path) → None

Load records from a file to Mongo DB.

mark_records_as_analyzed(record_list: xplogger.experiment_manager.record.record_list.RecordList) → None

Mark records as analyzed in the db.

Parameters

record_list (RecordList) –

ray_get_records() → xplogger.experiment_manager.record.record_list.RecordList

Get records from the db using ray.

ray_get_unanalyzed_records() → xplogger.experiment_manager.record.record_list.RecordList

Get unalalyzed records using ray.

ray_ignore_records_by_status(status: str) → xplogger.experiment_manager.record.record_list.RecordList

Get a list of records which do not match the status using ray.

replace_from_file(filepath: pathlib.Path, upsert: bool = False) → None

Replace records from a file to Mongo DB.

save_to_file(filepath: pathlib.Path) → None

Save mongo records to a file.

update_status(record_list: xplogger.experiment_manager.record.record_list.RecordList, new_status: str) → None

Mark records as analyzed in the db.

Parameters

record_list (RecordList) –

Module contents