ORIONIS API REFERENCE

THE ORIONIS API

Build with clarity.

Explore the building blocks of an async-first Python framework. Every module, class, and method — connected, searchable, and ready to build with.

Explore modules View classes

orionis.queues.drivers.database

module documentation
(source)

Undocumented

Class DatabaseQueueDriver Persist queued jobs using atomic conditional updates and expiring leases.
Function eligible_clauses Build predicates for an available or expired queue row.
Constant _CLAIM_ROUNDS Undocumented
Constant _ENCODER Undocumented
def eligible_clauses(queue: str, now: float) -> list[WhereClause]: (source)

Build predicates for an available or expired queue row.

Parameters
queue:strLogical queue whose jobs are eligible.
now:floatCurrent epoch timestamp.
Returns
list of WhereClausePredicates shared by candidate lookup and atomic claim.
_CLAIM_ROUNDS: int = (source)

Undocumented

Value
100
_ENCODER = (source)

Undocumented

Value
msgspec.json.Encoder()