Merge pull request #43 from ecmwf-projects/387-get-job

forward get job to compute api

Author: mcucchi9

ogc_api_processes_fastapi/clients.py

@@ -121,7 +121,7 @@ def get_jobs(self) -> List[models.StatusInfo]:
         """
 
     @abc.abstractmethod
-    def get_job(self, job_id: str) -> models.StatusInfo:
+    def get_job(self, job_id: str, response: fastapi.Response) -> models.StatusInfo:
         """Get status information of the job identified by `job_id`.
 
         Called with `GET /jobs/{job_id}`.
@@ -130,6 +130,8 @@ def get_job(self, job_id: str) -> models.StatusInfo:
         ----------
         job_id : str
             Identifier of the job.
+        response: fastapi.Response
+            Response.
 
         Returns
         -------

ogc_api_processes_fastapi/routers.py

@@ -35,7 +35,7 @@ def make_links_to_job(
     Returns
     -------
     List[models.Link]
-        Links to attach to jon
+        Links to attach to job.
     """
     rel_job_link = "self"
     title_job_link = None
@@ -292,11 +292,12 @@ def create_get_job_endpoint(
         operation_id="getJobStatus",
     )
     def get_job(
-        request: fastapi.Request,
         job_id: str,
+        request: fastapi.Request,
+        response: fastapi.Response,
     ) -> models.StatusInfo:
         """Show the status of a job."""
-        job = client.get_job(job_id=job_id)
+        job = client.get_job(job_id=job_id, response=response)
         job.links = make_links_to_job(job=job, request=request)
 
         return job

tests/conftest.py

@@ -77,10 +77,7 @@ def get_jobs(self) -> List[models.StatusInfo]:
         ]
         return jobs_list
 
-    def get_job(
-        self,
-        job_id: str,
-    ) -> models.StatusInfo:
+    def get_job(self, job_id: str, response: fastapi.Response) -> models.StatusInfo:
         status_info = models.StatusInfo(
             jobID=1, status=models.StatusCode.running, type=models.JobType.process
         )