Overview

package wittgenstein_job_queue.backends

Classes

• PostgresQueueBackend

wittgenstein_job_queue.backends.PostgresQueueBackend

mkapi_definition_mkapi class PostgresQueueBackend(engine: Engine, table_name: str = 'job_queue_message')

Bases : QueueBackend

Methods

• enqueue

• claim_next

• mark_done

• mark_failed

• is_drained

wittgenstein_job_queue.backends.PostgresQueueBackend.enqueue

mkapi_definition_mkapi method PostgresQueueBackend.enqueue(queue_name: str, payload: dict[str, Any], *, max_attempts: int = 3) → Job

wittgenstein_job_queue.backends.PostgresQueueBackend.claim_next

mkapi_definition_mkapi method PostgresQueueBackend.claim_next(queue_name: str, worker_id: str) → Job | None

wittgenstein_job_queue.backends.PostgresQueueBackend.mark_done

mkapi_definition_mkapi method PostgresQueueBackend.mark_done(job_id: str) → None

wittgenstein_job_queue.backends.PostgresQueueBackend.mark_failed

mkapi_definition_mkapi method PostgresQueueBackend.mark_failed(job_id: str, error: str) → None

wittgenstein_job_queue.backends.PostgresQueueBackend.is_drained

mkapi_definition_mkapi method PostgresQueueBackend.is_drained(queue_name: str) → bool