mainframe.ingestion
===================

.. py:module:: mainframe.ingestion

.. autoapi-nested-parse::

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



Attributes
----------

.. autoapisummary::

   mainframe.ingestion.retry_results
   mainframe.ingestion.retry_backlog
   mainframe.ingestion.RETRY_BATCH_SIZE


Functions
---------

.. autoapisummary::

   mainframe.ingestion.retry_ingestion
   mainframe.ingestion.retry_package


Module Contents
---------------

.. py:data:: retry_results

.. py:data:: retry_backlog

.. py:data:: RETRY_BATCH_SIZE
   :value: 20


.. py:function:: retry_ingestion(engine: sqlalchemy.Engine, pypi_client: mainframe.pypi.PyPIClient) -> None

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


.. py:function:: retry_package(session: sqlalchemy.orm.Session, pending: mainframe.models.orm.IngestionRetry, pypi_client: mainframe.pypi.PyPIClient, now: datetime.datetime) -> str