_jobs - Chirp

data._jobs

module

Private Postgres durable-job store.

This Phase 1 module deliberately has no public re-export, app lifecycle wiring, handler registry, or executor. PostgreSQL owns every lifecycle transition; the Python object holds only an immutable…

Private Postgres durable-job store.

This Phase 1 module deliberately has no public re-export, app lifecycle wiring, handler registry, or executor. PostgreSQL owns every lifecycle transition; the Python object holds only an immutable database reference and lease duration.

data._jobs

Name	Type	Default	Description
`type`		—
`qualified_name`		—
`element_type`		—
`description`		—
`source_file`		—
`line_number`		—
`is_autodoc`		—
`autodoc_element`		—
`_autodoc_template`		—
`_autodoc_url_path`		—
`_autodoc_page_type`		—
`title`		—
`doc_content_hash`		—

Symbols on this page

class JobStoreError

Base error for the private provisional job store.

class JobMigrationRequiredError

Raised when the reviewed durable-job migration has not been applied.

class JobSchemaVersionError

Raised when the database job schema is not the version this store expects.

class JobValidationError

Raised before invalid or unbounded durable data reaches PostgreSQL.

class JobQueueConfigurationError

Raised when callers disagree about one queue's persisted capacity.

class StaleJobClaimError

Raised when an owner/token pair no longer owns an active lease.

class _JobQueryError

Redacted database failure retaining only SQLSTATE for internal routing.

class EnqueueResult

Private enqueue result distinguishing insertion from idempotent reuse.

class JobProgress

Bounded advisory progress persisted under the active lease fence.

class ClaimedJob

Immutable attempt snapshot and the opaque fence needed to settle it.

class RetryResult

State and database-derived availability after a retryable failure.

class JobSnapshot

Private read model for tests and future operator projections.

class _SchemaRow class _QueueRow class _JobIdRow class _LeaseRow class _ProgressRow class _RetryRow function migration_directory

Return the package-shipped migration directory for private tooling/tests.

class PostgresJobStore

Private Phase 1 durable store; no handler or poller starts here.

JobStoreError

class

Base error for the private provisional job store.

JobMigrationRequiredError

class

Raised when the reviewed durable-job migration has not been applied.

JobSchemaVersionError

class

Raised when the database job schema is not the version this store expects.

JobValidationError

class

Raised before invalid or unbounded durable data reaches PostgreSQL.

JobQueueConfigurationError

class

Raised when callers disagree about one queue's persisted capacity.

StaleJobClaimError

class

Raised when an owner/token pair no longer owns an active lease.

_JobQueryError

class

Redacted database failure retaining only SQLSTATE for internal routing.

EnqueueResult

class

Private enqueue result distinguishing insertion from idempotent reuse.

JobProgress

class

Bounded advisory progress persisted under the active lease fence.

ClaimedJob

class

Immutable attempt snapshot and the opaque fence needed to settle it.

RetryResult

class

State and database-derived availability after a retryable failure.

JobSnapshot

class

Private read model for tests and future operator projections.

_SchemaRow

class

_QueueRow

class

_JobIdRow

class

_LeaseRow

class

_ProgressRow

class

_RetryRow

class

migration_directory

function

def migration_directory() -> Path

Return the package-shipped migration directory for private tooling/tests.

No parameters.

PostgresJobStore

class

Private Phase 1 durable store; no handler or poller starts here.

View source · /home/runner/work/chirp/chirp/site/../src/chirp/data/_jobs.py:1