Merge f93a0e9 into e7a4e13

app/meticulous/_input_queue.py

@@ -26,6 +26,16 @@ def pop(self):
         _, taskjson = heapq.heappop(self.queue)
         return taskjson
 
+    def save(self):
+        """
+        Get json serialization of queue
+        """
+        result = []
+        while self.queue:
+            priority, taskjson = heapq.heappop(self.queue)
+            result.append({"priority": priority, "task": taskjson})
+        return result
+
 
 def get_input_queue():
     """

app/meticulous/_input_queue_test.py

@@ -17,3 +17,20 @@ def test_priority():
     task = manager.pop()
     # Verify
     assert task["name"] == "now"  # noqa=S101 # nosec
+
+
+def test_save():
+    """
+    Ensure tasks are pulled off for suspension
+    """
+    # Setup
+    manager = get_input_queue()
+    manager.add(10, {"name": "later"})
+    manager.add(1, {"name": "now"})
+    # Exercise
+    tasks = manager.save()
+    # Verify
+    assert tasks == [  # noqa=S101 # nosec
+        {"priority": 1, "task": {"name": "now"}},
+        {"priority": 10, "task": {"name": "later"}},
+    ]