Fix return value for job pagination

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 1.5.1
+* Jobs pagination fix
+
 ## 1.5.0
 * Set autosave-every to 60
 

pygeoapi_kubernetes_papermill/kubernetes.py

@@ -133,7 +133,7 @@ def __init__(self, manager_def: dict) -> None:
         self.batch_v1 = k8s_client.BatchV1Api()
         self.core_api = k8s_client.CoreV1Api()
 
-    def get_jobs(self, status=None, limit=None, offset=None) -> list[JobDict]:
+    def get_jobs(self, status=None, limit=None, offset=None) -> dict:
         """
         Get process jobs, optionally filtered by status
 
@@ -154,6 +154,8 @@ def get_jobs(self, status=None, limit=None, offset=None) -> list[JobDict]:
             if is_k8s_job_name(k8s_job.metadata.name)
         ]
 
+        number_matched = len(k8s_jobs)
+
         # NOTE: need to paginate before expensive single job serialization
         if offset:
             k8s_jobs = k8s_jobs[offset:]
@@ -163,9 +165,13 @@ def get_jobs(self, status=None, limit=None, offset=None) -> list[JobDict]:
 
         # TODO: implement status filter
 
-        return [
-            job_from_k8s(k8s_job, self._job_message(k8s_job)) for k8s_job in k8s_jobs
-        ]
+        return {
+            "jobs": [
+                job_from_k8s(k8s_job, self._job_message(k8s_job))
+                for k8s_job in k8s_jobs
+            ],
+            "numberMatched": number_matched,
+        }
 
     def get_job(self, job_id) -> Optional[JobDict]:
         """

tests/test_kubernetes_manager.py

@@ -260,8 +260,8 @@ def test_get_jobs_handles_container_status_null(
 ):
     # NOTE: this test could be reduced to only test _job_message() if the excessive
     #       mocking causes issues
-    jobs = manager.get_jobs()
-    assert [job["message"] for job in jobs] == [""]
+    job_data = manager.get_jobs()
+    assert [job["message"] for job in job_data["jobs"]] == [""]
 
 
 def test_execute_process_sync_also_returns_mime_type(
@@ -292,9 +292,9 @@ def test_accepted_jobs_show_events(
     mock_list_events,
     manager: KubernetesManager,
 ):
-    jobs = manager.get_jobs()
+    job_data = manager.get_jobs()
 
-    assert jobs[0]["message"] == "last event"
+    assert job_data["jobs"][0]["message"] == "last event"
 
 
 def test_secret_job_annotation_parameters_are_hidden():
@@ -374,7 +374,9 @@ def test_kubernetes_manager_handles_pagination(
     many_k8s_jobs,
 ):
     with mock_list_jobs_with(*many_k8s_jobs):
-        jobs = manager.get_jobs(offset=3, limit=2)
+        job_data = manager.get_jobs(offset=3, limit=2)
 
+    jobs = job_data["jobs"]
     assert len(jobs) == 2
     assert [job["identifier"] for job in jobs] == ["job-3", "job-4"]
+    assert job_data["numberMatched"] == 13