Added delete task API. (#127)

Function accepts task id and performs deleting.

Signed-off-by: Nurlan <nabzalbekov0@gmail.com>
(cherry picked from commit 2c73825)

opensearch_py_ml/ml_commons/ml_commons_client.py

@@ -277,3 +277,20 @@ def delete_model(self, model_id: str) -> object:
             method="DELETE",
             url=API_URL,
         )
+
+    def delete_task(self, task_id: str) -> object:
+        """
+        This method deletes a task from opensearch cluster (using ml commons api)
+
+        :param task_id: unique id of the task
+        :type task_id: string
+        :return: returns a json object, with detailed information about the deleted task
+        :rtype: object
+        """
+
+        API_URL = f"{ML_BASE_URI}/tasks/{task_id}"
+
+        return self._client.transport.perform_request(
+            method="DELETE",
+            url=API_URL,
+        )

tests/ml_commons/test_ml_commons_client.py

@@ -201,6 +201,13 @@ def test_integration_model_train_upload_full_cycle():
                         raised == False
                     ), "Raised Exception in generating sentence embedding"
 
+                try:
+                    delete_task_obj = ml_client.delete_task(task_id)
+                    assert delete_task_obj.get("result") == "deleted"
+                except:  # noqa: E722
+                    raised = True
+                assert raised == False, "Raised Exception in deleting task"
+
                 try:
                     ml_client.unload_model(model_id)
                     for i in range(int(UNLOAD_TIMEOUT / 10)):