orionis.queues.failed.repository.DatabaseFailedJobRepository

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

class documentation

class DatabaseFailedJobRepository(IFailedJobRepository): (source)

Constructor: DatabaseFailedJobRepository(connection, table)

View In Hierarchy

Retain failed envelopes and diagnostics in framework-owned DB storage.

Method	`__init__`	Bind failure storage to a framework database connection.
Async Method	`_ensureSchema`	Create the failure table on first use.
Async Method	`all`	Return recorded failures in chronological order.
Async Method	`close`	Leave the shared database connection under its manager's ownership.
Async Method	`find`	Find one persisted failure by identifier.
Async Method	`forget`	Remove one recorded failure.
Async Method	`record`	Record a terminal failure once for this reservation token.
Class Variable	`__slots__`	Undocumented
Instance Variable	`_connection`	Undocumented
Instance Variable	`_definition`	Undocumented
Instance Variable	`_ready`	Undocumented
Instance Variable	`_ready_lock`	Undocumented

def __init__(self, connection: IConnection, table: str = 'failed_jobs'): (source) ¶

Bind failure storage to a framework database connection.

Parameters
connection:`IConnection`	Shared framework connection used for failure persistence.
table:`str, optional`	Logical table name for recorded failures.

Returns
`None`	Complete the documented operation without returning a value.

async def _ensureSchema(self): (source) ¶

Create the failure table on first use.

Returns
`None`	Ensure the failure storage exists.

async def all(self) -> tuple[FailedJob, ...]: (source) ¶

overrides orionis.queues.contracts.failed_repository.IFailedJobRepository.all

Return recorded failures in chronological order.

Returns
`tuple of FailedJob`	Persisted failed jobs ordered by timestamp and identifier.

async def close(self): (source) ¶

overrides orionis.queues.contracts.failed_repository.IFailedJobRepository.close

Leave the shared database connection under its manager's ownership.

Returns
`None`	Preserve the framework-managed connection lifecycle.

async def find(self, failure_id: str) -> FailedJob | None: (source) ¶

overrides orionis.queues.contracts.failed_repository.IFailedJobRepository.find

Find one persisted failure by identifier.

Parameters
failure_id:`str`	Stable failure identifier returned by the repository.

Returns
`FailedJob or None`	Recorded failure or no matching record.

async def forget(self, failure_id: str) -> bool: (source) ¶

overrides orionis.queues.contracts.failed_repository.IFailedJobRepository.forget

Remove one recorded failure.

Parameters
failure_id:`str`	Stable identifier of the failure to remove.

Returns
`bool`	Whether a failure was removed.

async def record(self, reserved: ReservedJob, connection: str, exception: Exception) -> FailedJob: (source) ¶

overrides orionis.queues.contracts.failed_repository.IFailedJobRepository.record

Record a terminal failure once for this reservation token.

Parameters
reserved:`ReservedJob`	Reservation whose encoded envelope must remain retryable.
connection:`str`	Queue connection on which the job failed.
exception:`Exception`	Original failure including its traceback.

Returns
`FailedJob`	Persisted failure or its existing idempotent record.

__slots__: tuple[str, ...] = (source) ¶

overrides orionis.queues.contracts.failed_repository.IFailedJobRepository.__slots__

Undocumented

_connection = (source) ¶

Undocumented

_definition = (source) ¶

Undocumented

_ready: bool = (source) ¶

Undocumented

_ready_lock = (source) ¶

Undocumented