diff --git a/backend/app/services/ingest_core.py b/backend/app/services/ingest_core.py index ba628f7..5cfaf5c 100644 --- a/backend/app/services/ingest_core.py +++ b/backend/app/services/ingest_core.py @@ -36,6 +36,7 @@ from sqlalchemy import delete, func, select, text from sqlalchemy.dialects.postgresql import insert as pg_insert from .gallery_dl import DownloadResult, ErrorType, make_run_stats +from .native_ingest_common import NativeAuthError, NativeDriftError log = logging.getLogger(__name__) @@ -88,6 +89,7 @@ class Ingester: ledger_key: Callable[[object], str], platform: str, error_base: type[Exception], + drift_label: str | None = None, ): self.client = client self.downloader = downloader @@ -99,6 +101,10 @@ class Ingester: self._ledger_key = ledger_key self._platform = platform self._error_base = error_base + # Human label for the API_DRIFT message ("