From e3df341ea0418f3bcf3a40f257a545633c495be5 Mon Sep 17 00:00:00 2001 From: Christian Chwala Date: Mon, 13 Jul 2026 21:18:15 +0200 Subject: [PATCH] chore: remove unused api_pull entrypoint The api_fetcher container handles HTTP/API polling by writing JSON files to the shared incoming volume, which the parser then processes. This file-based approach provides consistent archiving for cold storage. Removals: - parser/entrypoints/api_pull.py (stub entrypoint) - 'api_pull' from valid_entrypoints in generate_config.py - 'api_pull' from entrypoint documentation in users.yml Retained: - sftp_pull entrypoint stub (still planned for remote SFTP polling) Tests: 90 passing --- parser/entrypoints/api_pull.py | 6 ------ scripts/generate_config.py | 2 +- users.yml | 1 - 3 files changed, 1 insertion(+), 8 deletions(-) delete mode 100644 parser/entrypoints/api_pull.py diff --git a/parser/entrypoints/api_pull.py b/parser/entrypoints/api_pull.py deleted file mode 100644 index ccc1620..0000000 --- a/parser/entrypoints/api_pull.py +++ /dev/null @@ -1,6 +0,0 @@ -"""API pull entrypoint — polls an HTTP endpoint and writes JSON data. - -Not yet implemented. Placeholder so the module exists for import checking. -""" - -raise NotImplementedError("api_pull entrypoint is not yet implemented") diff --git a/scripts/generate_config.py b/scripts/generate_config.py index df4dce1..a12b419 100644 --- a/scripts/generate_config.py +++ b/scripts/generate_config.py @@ -91,7 +91,7 @@ def _validate(users: list[dict]) -> None: ) # Validate entrypoint if specified entrypoint = src.get("entrypoint", "sftp_push") - valid_entrypoints = {"sftp_push", "sftp_pull", "api_pull"} + valid_entrypoints = {"sftp_push", "sftp_pull"} if entrypoint not in valid_entrypoints: raise ValueError( f"Source {src['id']!r} for user {uid!r} has unknown entrypoint " diff --git a/users.yml b/users.yml index fbb1697..744dd1a 100644 --- a/users.yml +++ b/users.yml @@ -36,7 +36,6 @@ # entrypoint — Which ingestion loop to run for this source (default: "sftp_push"). # "sftp_push" — watch a local directory fed by SFTP. # "sftp_pull" — poll a remote SFTP server (not yet implemented). -# "api_pull" — poll an HTTP/JSON API (not yet implemented). # csv_config — (only for parser: csv_generic) Format configuration: # read_csv_kwargs — dict of kwargs forwarded to pd.read_csv # (e.g. sep, encoding, decimal, skiprows).