fix: cumulus deletion is causing ES deletes to persist

Author: wphyojpl

cumulus_lambda_functions/uds_api/granules_api.py

@@ -1,5 +1,6 @@
 import json
 import os
+from time import sleep
 from typing import Union
 
 from starlette.responses import Response, JSONResponse
@@ -264,8 +265,9 @@ async def delete_single_granule_dapa_actual(request: Request, collection_id: str
         cumulus_lambda_prefix = os.getenv('CUMULUS_LAMBDA_PREFIX')
         cumulus = GranulesQuery('https://na/dev', 'NA')
         cumulus.with_collection_id(collection_id)
-        # cumulus_delete_result = cumulus.delete_entry(cumulus_lambda_prefix, granule_id)  # TODO not sure it is correct granule ID
-        # LOGGER.debug(f'cumulus_delete_result: {cumulus_delete_result}')
+        cumulus_delete_result = cumulus.delete_entry(cumulus_lambda_prefix, granule_id)  # TODO not sure it is correct granule ID
+        LOGGER.debug(f'cumulus_delete_result: {cumulus_delete_result}')
+        sleep(3)  # Testing if this helps
         es_delete_result = GranulesDbIndex().delete_entry(collection_identifier.tenant,
                                                           collection_identifier.venue,
                                                           granule_id

tests/integration_tests/test_granules_deletion.py

@@ -33,7 +33,7 @@ def setUp(self) -> None:
 
         self.tenant = 'UDS_LOCAL_TEST_3'  # 'uds_local_test'  # 'uds_sandbox'
         self.tenant_venue = 'DEV'  # 'DEV1'  # 'dev'
-        self.collection_name = 'AAA-03'  # 'uds_collection'  # 'sbx_collection'
+        self.collection_name = 'DDD-01'  # 'uds_collection'  # 'sbx_collection'
         # self.collection_version = '08'.replace('.', '')  # '2402011200'
         return
 
@@ -83,7 +83,7 @@ def test_delete_all(self):
         self.assertEqual(query_result.status_code, 200, f'wrong status code. {query_result.text}')
         response_json = json.loads(query_result.text)
         print(json.dumps(response_json, indent=4))
-        sleep(30)
+        sleep(10)
         post_url = f'{self.uds_url}collections/{collection_id}/items/'  # MCP Dev
         query_result = requests.get(url=post_url, headers=headers,)
         self.assertEqual(query_result.status_code, 200, f'wrong status code. {query_result.text}')