mainframe.ingestion

Bounded retries of durably accepted packages, independent of the RSS feed.

Attributes

retry_results
retry_backlog
RETRY_BATCH_SIZE

Functions

retry_ingestion(→ None)	Lock one due package at a time; retain failures with bounded backoff.
retry_package(→ str)

Module Contents

mainframe.ingestion.retry_results

mainframe.ingestion.retry_backlog

mainframe.ingestion.RETRY_BATCH_SIZE = 20

mainframe.ingestion.retry_ingestion(engine: sqlalchemy.Engine, pypi_client: mainframe.pypi.PyPIClient) → None

Lock one due package at a time; retain failures with bounded backoff.

mainframe.ingestion.retry_package(session: sqlalchemy.orm.Session, pending: mainframe.models.orm.IngestionRetry, pypi_client: mainframe.pypi.PyPIClient, now: datetime.datetime) → str