From bb46e147f0d4ce3145fdbb35acbec5e8a028e846 Mon Sep 17 00:00:00 2001 From: Max Chis Date: Sat, 26 Jul 2025 14:44:23 -0400 Subject: [PATCH] Fix typo in sync query parameters --- src/external/pdap/client.py | 4 ++-- tests/manual/external/pdap/sync/__init__.py | 0 .../pdap/{ => sync}/test_sync_agencies.py | 18 +++++++++++++++++- 3 files changed, 19 insertions(+), 3 deletions(-) create mode 100644 tests/manual/external/pdap/sync/__init__.py rename tests/manual/external/pdap/{ => sync}/test_sync_agencies.py (52%) diff --git a/src/external/pdap/client.py b/src/external/pdap/client.py index a68179fe..1447ae87 100644 --- a/src/external/pdap/client.py +++ b/src/external/pdap/client.py @@ -168,7 +168,7 @@ async def sync_agencies( headers=headers, params={ "page": params.page, - "update_at": params.cutoff_date + "updated_at": params.cutoff_date } ) response_info = await self.access_manager.make_request(request_info) @@ -198,7 +198,7 @@ async def sync_data_sources( headers=headers, params={ "page": params.page, - "update_at": params.cutoff_date + "updated_at": params.cutoff_date } ) response_info = await self.access_manager.make_request(request_info) diff --git a/tests/manual/external/pdap/sync/__init__.py b/tests/manual/external/pdap/sync/__init__.py new file mode 100644 index 00000000..e69de29b diff --git a/tests/manual/external/pdap/test_sync_agencies.py b/tests/manual/external/pdap/sync/test_sync_agencies.py similarity index 52% rename from tests/manual/external/pdap/test_sync_agencies.py rename to tests/manual/external/pdap/sync/test_sync_agencies.py index 6eeaf7c3..16be5d9d 100644 --- a/tests/manual/external/pdap/test_sync_agencies.py +++ b/tests/manual/external/pdap/sync/test_sync_agencies.py @@ -1,6 +1,8 @@ import pytest import time +from pendulum import tomorrow + from src.core.tasks.scheduled.sync.agency.dtos.parameters import AgencySyncParameters @@ -18,4 +20,18 @@ async def test_sync_agencies(pdap_client_dev): print(response) duration = end - start - print(f"Duration: {duration:.4f} seconds") \ No newline at end of file + print(f"Duration: {duration:.4f} seconds") + +@pytest.mark.asyncio +async def test_sync_agencies_cutoff(pdap_client_dev): + + start = time.perf_counter() + response = await pdap_client_dev.sync_agencies( + params=AgencySyncParameters( + page=1, + cutoff_date=tomorrow() + ) + ) + end = time.perf_counter() + print(response) +