X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FRO.git;a=blobdiff_plain;f=RO-SDN-arista_cloudvision%2Fosm_rosdn_arista_cloudvision%2FaristaTask.py;fp=RO-SDN-arista_cloudvision%2Fosm_rosdn_arista_cloudvision%2FaristaTask.py;h=6af7c4333ad6e917bb73bd91229f3ebb7731b0da;hp=12f3920c0b46f9f3e75f031b3efa7f42d5c820d3;hb=6986244790d12f4ce734fd5cd2599e84b29c3f84;hpb=21c55d66c67cce097adab2f237356388b1a16077

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 12f3920c..6af7c433 100644
--- 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:
 
         return new_data
 
+    def get_pending_tasks(self):
+        return self.cvpClientApi.get_tasks_by_status("Pending")
+
+    def get_pending_tasks_old(self):
+        taskList = []
+        tasksField = {
+            "workOrderId": "workOrderId",
+            "workOrderState": "workOrderState",
+            "currentTaskName": "currentTaskName",
+            "description": "description",
+            "workOrderUserDefinedStatus": "workOrderUserDefinedStatus",
+            "note": "note",
+            "taskStatus": "taskStatus",
+            "workOrderDetails": "workOrderDetails",
+        }
+        tasks = self.cvpClientApi.get_tasks_by_status("Pending")
+
+        # Reduce task data to required fields
+        for task in tasks:
+            taskFacts = {}
+            for field in task.keys():
+                if field in tasksField:
+                    taskFacts[tasksField[field]] = task[field]
+
+            taskList.append(taskFacts)
+
+        return taskList
+
     def task_action(self, tasks, wait, state):
         changed = False
         data = dict()