aside.models.database module

Methods for serialization of Task and Queue.

check_locking(func)

class Database(queue_manager: aside.models.models.QueueManager, data_dir: Optional[os.PathLike] = None)

Bases: object

Serialize into files on disk in tree-like directories.

__init__(queue_manager: aside.models.models.QueueManager, data_dir: Optional[os.PathLike] = None)

Set up data directory.

observe_task(event: aside.boilerplate.observable.Event)

Observe tasks collection events raised by queue manager.

Regexp string for matching events: .*/tasks/[^/]*

observe_task_metadata(event: aside.boilerplate.observable.Event)

Observe task events raised by queue manager.

Regexp string for matching events: .*/tasks/[^/]*/[^/]*

observe_queue(event: aside.boilerplate.observable.Event)

Observe queue collection events raised by queue manager.

Regexp string for matching events: queues/[^/]*

observe_queue_metadata(event: aside.boilerplate.observable.Event)

Observe queue events raised by queue manager.

Regexp string for matching events: queues/[^/]*/[^/]*

populate_manager_from_disk(queue_manager: aside.models.models.QueueManager)

Take queue manager and fill it with queues from disk.

populate_queue_from_disk(queue: aside.models.models.Queue) → None

Read queue by id from disk.