DataStoreSqlite#

class DataStoreSqlite(*args, **kwargs)#

Attributes:

completed
db
describe
limit
locked: returns if lock_pid is NULL or doesn’t exist.
logs: returns all log records
members
mode: string that references datastore mode, override in override in subclass constructor
not_completed: returns database records of type NotCompleted
record_type: class name of completed results
source: string that references connecting to data store, override in subclass constructor
summary_logs: returns a table summarising log files
summary_not_completed: returns a table summarising not completed results

Methods

`lock`()	if writable, and not locked, locks the database to this pid
`md5`(unique_id)
`read`(identifier)	identifier string formed from Path(table_name) / identifier
`unlock`([force])	remove a lock if pid matches.
`write`(*, unique_id, data)	writes a completed record ending with .suffix
`write_not_completed`(*, unique_id, data)	writes a not completed record as json

md5(unique_id: str) → str | None#

Parameters:

property mode: Mode#: string that references datastore mode, override in override in subclass constructor

read(identifier: str) → str | bytes#: identifier string formed from Path(table_name) / identifier

property source: str | Path#: string that references connecting to data store, override in subclass constructor

property summary_logs: TabularType#: returns a table summarising log files

property summary_not_completed: c3_types.TabularType#: returns a table summarising not completed results

unlock(force=False) → None#: remove a lock if pid matches. If force, ignores pid. ignored if mode is READONLY

write(*, unique_id: str, data: str | bytes) → DataMemberABC#

writes a completed record ending with .suffix

Parameters:

Returns:

Notes

Drops any not-completed member corresponding to this identifier

write_not_completed(*, unique_id: str, data: str | bytes) → DataMemberABC#

writes a not completed record as json

Parameters:

Returns: