Update unity_sds_client with Data Service Delete

.github/workflows/unity-py-python-app.yml

@@ -52,8 +52,9 @@ jobs:
       if: steps.changes.outputs.src == 'true'
       run: |
         unity_py_proposed_version=`poetry version -s`
-        echo "curl -s -o /dev/null -w \"%{http_code}\" https://pypi.org/project/unity-sds-client/$unity_py_proposed_version/"
-        status_code=`curl -s -o /dev/null -w "%{http_code}" https://pypi.org/project/unity-sds-client/$unity_py_proposed_version/`
+        #  https://pypi.org/pypi/unity-sds-client/0.8.0/json
+        echo "curl -s -o /dev/null -w \"%{http_code}\" https://pypi.org/pypi/unity-sds-client/$unity_py_proposed_version/json"
+        status_code=`curl -s -o /dev/null -w \"%{http_code}\" https://pypi.org/pypi/unity-sds-client/$unity_py_proposed_version/json`
         echo "Received status code of $status_code"
         if ((status_code == 200)); then
           echo "Version already exists."

libs/unity-py/CHANGELOG.md

@@ -5,6 +5,22 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.8.0] - 2025-1-14
+
+### Added
+
+### Fixed
+
+### Changed
+
+    Updated the unity-py to include the Data Service Delete.
+
+### Removed
+
+### Security
+
+### Deprecated
+
 ## [0.7.0] - 2024-11-21
 
 ### Added

libs/unity-py/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "unity-sds-client"
-version = "0.7.0"
+version = "0.8.0"
 description = "Unity-Py is a Python client to simplify interactions with NASA's Unity Platform."
 authors = ["Anil Natha, Mike Gangl"]
 readme = "README.md"

libs/unity-py/tests/test_unity_data_service.py

@@ -1,6 +1,7 @@
 from unity_sds_client.unity import Unity
 from unity_sds_client.unity_exception import UnityException
 from unity_sds_client.unity_session import UnitySession
+from unity_sds_client.unity import UnityEnvironments
 from unity_sds_client.resources.collection import Collection
 from unity_sds_client.unity_services import UnityServices as Services
 
@@ -47,4 +48,19 @@ def test_collection_creation(cleanup_update_test):
     s.set_project("unity")
     s.set_venue("test")
     ds = s.client(Services.DATA_SERVICE)
-    ds.create_collection(Collection("urn:nasa:unity:unity:test:my_collection_id"), True)
+    ds.create_collection(Collection("urn:nasa:unity:unity:test:my_collection_id"), True)
+
+def test_collection_deletion():
+
+    unity = Unity(UnityEnvironments.TEST)
+    token = unity._session.get_auth().get_token()
+    data_service = unity.client(Services.DATA_SERVICE)
+
+    collections = data_service.get_collections(100)
+
+    granule_id = 'urn:nasa:unity:emit:dev:unity-tutorial___1:summary_table.txt'
+
+    for i in range(len(collections)):
+        if granule_id in collections[i].collection_id:
+            data_service.delete_collection_data(collections[i], granule_id)
+            break

libs/unity-py/unity_sds_client/services/data_service.py

@@ -190,3 +190,20 @@ def define_custom_metadata(self, metadata: dict):
                                 params={"venue": self._session._venue}, json=metadata)
         if response.status_code != 200:
             raise UnityException("Error adding custom metadata: " + response.message)
+
+    #
+    #Delete single granule from a given Collection
+    #
+    def delete_collection_data(self, collection: type = Collection, granule_id: str = None):
+        #Must provide granule_id
+        if (granule_id == "") or (granule_id is None):
+            raise Exception("Error deleting collection data: Please provide granule ID")
+
+        else:
+            url = f'{self.endpoint}am-uds-dapa/collections/{collection.collection_id}/items/{granule_id}/'        
+            token = self._session.get_auth().get_token()        
+            header = {"Authorization": f"Bearer {token}"}
+            response = requests.delete(url=url, headers=header)
+            print(response.status_code)
+            if response.status_code != 200:
+                raise UnityException("Error deleting collection: " + response.reason)