Revert "Removing unused methods from RO module"

[osm/RO.git] / RO-SDN-arista_cloudvision / osm_rosdn_arista_cloudvision / aristaTask.py

diff --git a/RO-SDN-arista_cloudvision/osm_rosdn_arista_cloudvision/aristaTask.py b/RO-SDN-arista_cloudvision/osm_rosdn_arista_cloudvision/aristaTask.py
index 12f3920..6af7c43 100644 (file)
--- a/RO-SDN-arista_cloudvision/osm_rosdn_arista_cloudvision/aristaTask.py
+++ b/RO-SDN-arista_cloudvision/osm_rosdn_arista_cloudvision/aristaTask.py
@@ -72,6 +72,34 @@ class AristaCVPTask:
 \r
         return new_data\r
 \r
+    def get_pending_tasks(self):\r
+        return self.cvpClientApi.get_tasks_by_status("Pending")\r
+\r
+    def get_pending_tasks_old(self):\r
+        taskList = []\r
+        tasksField = {\r
+            "workOrderId": "workOrderId",\r
+            "workOrderState": "workOrderState",\r
+            "currentTaskName": "currentTaskName",\r
+            "description": "description",\r
+            "workOrderUserDefinedStatus": "workOrderUserDefinedStatus",\r
+            "note": "note",\r
+            "taskStatus": "taskStatus",\r
+            "workOrderDetails": "workOrderDetails",\r
+        }\r
+        tasks = self.cvpClientApi.get_tasks_by_status("Pending")\r
+\r
+        # Reduce task data to required fields\r
+        for task in tasks:\r
+            taskFacts = {}\r
+            for field in task.keys():\r
+                if field in tasksField:\r
+                    taskFacts[tasksField[field]] = task[field]\r
+\r
+            taskList.append(taskFacts)\r
+\r
+        return taskList\r
+\r
     def task_action(self, tasks, wait, state):\r
         changed = False\r
         data = dict()\r