diff --git a/src/core/tasks/scheduled/impl/sync_to_ds/README.md b/src/core/tasks/scheduled/impl/sync_to_ds/README.md index 488b52bb..3af42af8 100644 --- a/src/core/tasks/scheduled/impl/sync_to_ds/README.md +++ b/src/core/tasks/scheduled/impl/sync_to_ds/README.md @@ -17,7 +17,7 @@ Each task gathers requisite information from the SM database and sends a request Each DS endpoint follows the following format: ```text -/v3/source-manager/{entity}/{action} +/v3/sync/{entity}/{action} ``` Synchronizations are designed to occur on an hourly basis. diff --git a/src/external/pdap/impl/sync/agencies/add/core.py b/src/external/pdap/impl/sync/agencies/add/core.py index 276ff39d..a8f190ce 100644 --- a/src/external/pdap/impl/sync/agencies/add/core.py +++ b/src/external/pdap/impl/sync/agencies/add/core.py @@ -14,7 +14,7 @@ def __init__( self.request = request async def inner_logic(self) -> list[DSAppSyncAddResponseInnerModel]: - url: str = self.build_url("v3/source-manager/agencies/add") + url: str = self.build_url("v3/sync/agencies/add") raw_results = await self.post( url=url, model=self.request, diff --git a/src/external/pdap/impl/sync/agencies/delete/core.py b/src/external/pdap/impl/sync/agencies/delete/core.py index 41c0cfd0..f48e1b11 100644 --- a/src/external/pdap/impl/sync/agencies/delete/core.py +++ b/src/external/pdap/impl/sync/agencies/delete/core.py @@ -12,7 +12,7 @@ def __init__( self.ds_app_ids = ds_app_ids async def inner_logic(self) -> None: - url: str = self.build_url("v3/source-manager/agencies/delete") + url: str = self.build_url("v3/sync/agencies/delete") await self.post( url=url, model=DSAppSyncDeleteRequestModel( diff --git a/src/external/pdap/impl/sync/agencies/update/core.py b/src/external/pdap/impl/sync/agencies/update/core.py index 4c5673ac..6589c8b0 100644 --- a/src/external/pdap/impl/sync/agencies/update/core.py +++ b/src/external/pdap/impl/sync/agencies/update/core.py @@ -12,7 +12,7 @@ def __init__( self.request = request async def inner_logic(self) -> None: - url: str = self.build_url("v3/source-manager/agencies/update") + url: str = self.build_url("v3/sync/agencies/update") await self.post( url=url, model=self.request diff --git a/src/external/pdap/impl/sync/data_sources/add/core.py b/src/external/pdap/impl/sync/data_sources/add/core.py index 8eaa1b8b..c3576961 100644 --- a/src/external/pdap/impl/sync/data_sources/add/core.py +++ b/src/external/pdap/impl/sync/data_sources/add/core.py @@ -14,7 +14,7 @@ def __init__( self.request = request async def inner_logic(self) -> list[DSAppSyncAddResponseInnerModel]: - url: str = self.build_url("v3/source-manager/data-sources/add") + url: str = self.build_url("v3/sync/data-sources/add") raw_results = await self.post( url=url, model=self.request, diff --git a/src/external/pdap/impl/sync/data_sources/delete/core.py b/src/external/pdap/impl/sync/data_sources/delete/core.py index 7199c0ca..e58d1741 100644 --- a/src/external/pdap/impl/sync/data_sources/delete/core.py +++ b/src/external/pdap/impl/sync/data_sources/delete/core.py @@ -12,7 +12,7 @@ def __init__( self.ds_app_ids = ds_app_ids async def inner_logic(self) -> None: - url: str = self.build_url("v3/source-manager/data-sources/delete") + url: str = self.build_url("v3/sync/data-sources/delete") await self.post( url=url, model=DSAppSyncDeleteRequestModel( diff --git a/src/external/pdap/impl/sync/data_sources/update/core.py b/src/external/pdap/impl/sync/data_sources/update/core.py index 8bcaf57e..491f1676 100644 --- a/src/external/pdap/impl/sync/data_sources/update/core.py +++ b/src/external/pdap/impl/sync/data_sources/update/core.py @@ -12,7 +12,7 @@ def __init__( self.request = request async def inner_logic(self) -> None: - url: str = self.build_url("v3/source-manager/data-sources/update") + url: str = self.build_url("v3/sync/data-sources/update") await self.post( url=url, model=self.request diff --git a/src/external/pdap/impl/sync/meta_urls/add/core.py b/src/external/pdap/impl/sync/meta_urls/add/core.py index 98d6f016..8f1b3752 100644 --- a/src/external/pdap/impl/sync/meta_urls/add/core.py +++ b/src/external/pdap/impl/sync/meta_urls/add/core.py @@ -14,7 +14,7 @@ def __init__( self.request = request async def inner_logic(self) -> list[DSAppSyncAddResponseInnerModel]: - url: str = self.build_url("v3/source-manager/meta-urls/add") + url: str = self.build_url("v3/sync/meta-urls/add") raw_results = await self.post( url=url, model=self.request, diff --git a/src/external/pdap/impl/sync/meta_urls/delete/core.py b/src/external/pdap/impl/sync/meta_urls/delete/core.py index 08b6fd81..bde1dc8d 100644 --- a/src/external/pdap/impl/sync/meta_urls/delete/core.py +++ b/src/external/pdap/impl/sync/meta_urls/delete/core.py @@ -12,7 +12,7 @@ def __init__( self.ds_app_ids = ds_app_ids async def inner_logic(self) -> None: - url: str = self.build_url("v3/source-manager/meta-urls/delete") + url: str = self.build_url("v3/sync/meta-urls/delete") await self.post( url=url, model=DSAppSyncDeleteRequestModel( diff --git a/src/external/pdap/impl/sync/meta_urls/update/core.py b/src/external/pdap/impl/sync/meta_urls/update/core.py index 37e84da9..0c917535 100644 --- a/src/external/pdap/impl/sync/meta_urls/update/core.py +++ b/src/external/pdap/impl/sync/meta_urls/update/core.py @@ -12,7 +12,7 @@ def __init__( self.request = request async def inner_logic(self) -> None: - url: str = self.build_url("v3/source-manager/meta-urls/update") + url: str = self.build_url("v3/sync/meta-urls/update") await self.post( url=url, model=self.request diff --git a/tests/automated/integration/tasks/scheduled/impl/sync_to_ds/helpers.py b/tests/automated/integration/tasks/scheduled/impl/sync_to_ds/helpers.py index c90a9654..f6d1bd68 100644 --- a/tests/automated/integration/tasks/scheduled/impl/sync_to_ds/helpers.py +++ b/tests/automated/integration/tasks/scheduled/impl/sync_to_ds/helpers.py @@ -24,7 +24,7 @@ def extract_and_validate_sync_request( assert mock_pdap_client.access_manager.make_request.call_count == 1 request_info: RequestInfo = get_last_request(mock_pdap_client) assert request_info.type_ == RequestType.POST - full_expected_url: str = f"http://example.com/v3/source-manager/{expected_path}" + full_expected_url: str = f"http://example.com/v3/sync/{expected_path}" assert request_info.url == full_expected_url, f"Expected URL: {full_expected_url}, Actual URL: {request_info.url}" return expected_model(**request_info.json_)