orionis.queues.schema

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.

module documentation

(source)

Undocumented

Function	`build_failed_jobs_table`	Build the portable failed-job storage schema.
Function	`build_jobs_table`	Build the portable queue storage schema.
Function	`validate_table_name`	Validate a logical table identifier.
Constant	`_TABLE_NAME`	Undocumented

def build_failed_jobs_table(table: str) -> TableDefinition: (source) ¶

Build the portable failed-job storage schema.

Parameters
table:`str`	Logical table name for failed jobs.

Returns
`TableDefinition`	Failure schema retaining the original envelope and exception details.

def build_jobs_table(table: str) -> TableDefinition: (source) ¶

Build the portable queue storage schema.

Parameters
table:`str`	Logical table name for durable queued jobs.

Returns
`TableDefinition`	Queue schema with lease fencing and fractional epoch timestamps.

def validate_table_name(table: str) -> str: (source) ¶

Validate a logical table identifier.

Parameters
table:`str`	Logical table name without the database connection prefix.

Returns
`str`	Validated table identifier.

Raises
`QueueConfigurationError`	If the table identifier is invalid.

Undocumented

Value

re.compile(r'[A-Za-z_]\w*',
           re.ASCII)