saturn_engine.worker.inventory

Classes

BlockingInventory(*args, options, **kwargs)
BlockingSubInventory(*args, options, **kwargs)
CursorsState(after, partials, max_partials)
Inventory(*args, options, **kwargs)
Item(args, typing.Any], id, cursor, tags, ...)
IteratorInventory(*[, batch_size])
PendingItem(is_pending, item)
SubInventory(*args, options, **kwargs)

Exceptions

MaxRetriesError
RetryBatch(*, delay[, max_retries])