Merge pull request #46 from ecmwf-projects/remove-response-from-client

Remove response from client

Author: mcucchi9

ogc_api_processes_fastapi/clients.py

@@ -74,7 +74,6 @@ def post_process_execute(
         process_id: str,
         execution_content: models.Execute,
         request: fastapi.Request,
-        response: fastapi.Response,
     ) -> models.StatusInfo:
         """Post request for execution of the process identified by `process_id`.
 
@@ -89,8 +88,6 @@ def post_process_execute(
             (e.g. inputs values).
         request: fastapi.Request
             Request.
-        response: fastapi.Response
-            Response.
 
         Returns
         -------
@@ -121,7 +118,7 @@ def get_jobs(self) -> List[models.StatusInfo]:
         """
 
     @abc.abstractmethod
-    def get_job(self, job_id: str, response: fastapi.Response) -> models.StatusInfo:
+    def get_job(self, job_id: str) -> models.StatusInfo:
         """Get status information of the job identified by `job_id`.
 
         Called with `GET /jobs/{job_id}`.
@@ -130,8 +127,6 @@ def get_job(self, job_id: str, response: fastapi.Response) -> models.StatusInfo:
         ----------
         job_id : str
             Identifier of the job.
-        response: fastapi.Response
-            Response.
 
         Returns
         -------

ogc_api_processes_fastapi/routers.py

@@ -200,10 +200,7 @@ def post_process_execute(
     ) -> Any:
         """Create a new job."""
         status_info = client.post_process_execute(
-            process_id=process_id,
-            execution_content=request_content,
-            request=request,
-            response=response,
+            process_id=process_id, execution_content=request_content, request=request
         )
         status_info.links = [
             models.Link(
@@ -294,10 +291,9 @@ def create_get_job_endpoint(
     def get_job(
         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, response=response)
+        job = client.get_job(job_id=job_id)
         job.links = make_links_to_job(job=job, request=request)
 
         return job

tests/conftest.py

@@ -62,7 +62,6 @@ def post_process_execute(
         process_id: str,
         execution_content: models.Execute,
         request: fastapi.Request,
-        response: fastapi.Response,
     ) -> models.StatusInfo:
         status_info = models.StatusInfo(
             jobID=1, status=models.StatusCode.accepted, type=models.JobType.process
@@ -77,7 +76,7 @@ def get_jobs(self) -> List[models.StatusInfo]:
         ]
         return jobs_list
 
-    def get_job(self, job_id: str, response: fastapi.Response) -> models.StatusInfo:
+    def get_job(self, job_id: str) -> models.StatusInfo:
         status_info = models.StatusInfo(
             jobID=1, status=models.StatusCode.running, type=models.JobType.process
         )