in airavata_django_portal_sdk/user_storage/api.py [0:0]
def delete(request, data_product=None, data_product_uri=None):
"""
Delete replica for data product in this data store. One of `data_product`
or `data_product_uri` is required.
"""
if data_product is None:
data_product = _get_data_product(request, data_product_uri)
if remoteapi.is_remote_api_configured():
remoteapi.call(
request,
"/delete-file",
params={'data-product-uri': data_product.productUri},
method="delete")
return
else:
storage_resource_id, path = _get_replica_resource_id_and_filepath(data_product)
backend = get_user_storage_provider(request, storage_resource_id=storage_resource_id)
try:
backend.delete(path)
_delete_data_product(data_product.ownerName, path, storage_resource_id)
except Exception:
logger.exception(
"Unable to delete file {} for data product uri {}".format(
path, data_product.productUri
),
extra={'request': request}
)
raise