Skip to content

Commit 919b757

Browse files
committed
fix: add optional delete files flag
1 parent 0e16e7f commit 919b757

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

cumulus_lambda_functions/uds_api/granules_api.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -246,7 +246,7 @@ async def get_single_granule_dapa(request: Request, collection_id: str, granule_
246246

247247
@router.delete("/{collection_id}/items/{granule_id}")
248248
@router.delete("/{collection_id}/items/{granule_id}/")
249-
async def get_single_granule_dapa(request: Request, collection_id: str, granule_id: str):
249+
async def delete_single_granule_dapa(request: Request, collection_id: str, granule_id: str, delete_files: bool=True):
250250
authorizer: UDSAuthorizorAbstract = UDSAuthorizerFactory() \
251251
.get_instance(UDSAuthorizerFactory.cognito,
252252
es_url=os.getenv('ES_URL'),
@@ -275,6 +275,9 @@ async def get_single_granule_dapa(request: Request, collection_id: str, granule_
275275
)
276276
LOGGER.debug(f'es_delete_result: {es_delete_result}')
277277
es_delete_result = [Item.from_dict(k['_source']) for k in es_delete_result['hits']['hits']]
278+
if delete_files is False:
279+
LOGGER.debug(f'Not deleting files as it is set to false in the request')
280+
return {}
278281
s3 = AwsS3()
279282
for each_granule in es_delete_result:
280283
s3_urls = [v.href for k, v in each_granule.assets.items()]

0 commit comments

Comments
 (0)