saturn_engine.worker.work_manager#

Classes

ItemsSync(add, drop)

WorkManager(*, services[, client])

WorkSync(queues, resources, ...)