jobs_service

Author: pcrespov

services/api-server/src/simcore_service_api_server/_service_job.py renamed to services/api-server/src/simcore_service_api_server/_service_jobs.py

@@ -27,9 +27,11 @@
 DEFAULT_PAGINATION_LIMIT = 999  # MAXIMUM_NUMBER_OF_ITEMS_PER_PAGE - 1
 
 
-class JobService:
+class JobsService:
+    # clients
     _web_rest_api: AuthSession
     _web_rpc_api: WbApiRpcClient
+    # context
     _user_id: UserID
     _product_name: ProductName
 

services/api-server/src/simcore_service_api_server/_service_solvers.py

@@ -17,7 +17,7 @@
     SolverServiceListJobsFiltersError,
 )
 
-from ._service_job import JobService
+from ._service_jobs import JobsService
 from .models.api_resources import compose_resource_name
 from .models.schemas.jobs import Job
 from .models.schemas.solvers import Solver, SolverKeyId
@@ -28,15 +28,15 @@
 
 class SolverService:
     _catalog_service: CatalogService
-    _job_service: JobService
+    _jobs_service: JobsService
 
     def __init__(
         self,
         catalog_service: CatalogService,
-        job_service: JobService,
+        jobs_service: JobsService,
     ):
         self._catalog_service = catalog_service
-        self._job_service = job_service
+        self._jobs_service = jobs_service
 
     async def get_solver(
         self,
@@ -116,7 +116,7 @@ async def list_jobs(
         )
 
         # Use the common implementation from JobService
-        return await self._job_service.list_jobs_by_resource_prefix(
+        return await self._jobs_service.list_jobs_by_resource_prefix(
             offset=offset,
             limit=limit,
             job_parent_resource_name_prefix=job_parent_resource_name_prefix,

services/api-server/src/simcore_service_api_server/_service_studies.py

@@ -6,21 +6,21 @@
 from models_library.rpc_pagination import PageLimitInt
 from simcore_service_api_server.models.schemas.studies import StudyID
 
-from ._service_job import JobService
+from ._service_jobs import JobsService
 from .models.api_resources import compose_resource_name
 from .models.schemas.jobs import Job
 
 DEFAULT_PAGINATION_LIMIT = MAXIMUM_NUMBER_OF_ITEMS_PER_PAGE - 1
 
 
 class StudiesService:
-    _job_service: JobService
+    _jobs_service: JobsService
 
     def __init__(
         self,
-        job_service: JobService,
+        jobs_service: JobsService,
     ):
-        self._job_service = job_service
+        self._jobs_service = jobs_service
 
     async def list_jobs(
         self,
@@ -45,7 +45,7 @@ async def list_jobs(
         )
 
         # Use the common implementation from JobService
-        return await self._job_service.list_jobs_by_resource_prefix(
+        return await self._jobs_service.list_jobs_by_resource_prefix(
             offset=offset,
             limit=limit,
             job_parent_resource_name_prefix=job_parent_resource_name_prefix,

services/api-server/src/simcore_service_api_server/api/dependencies/services.py

@@ -9,7 +9,7 @@
 from servicelib.rabbitmq import RabbitMQRPCClient
 from simcore_service_api_server._service_studies import StudiesService
 
-from ..._service_job import JobService
+from ..._service_jobs import JobsService
 from ..._service_solvers import SolverService
 from ...services_rpc.catalog import CatalogService
 from ...services_rpc.wb_api_server import WbApiRpcClient
@@ -55,17 +55,17 @@ def get_catalog_service(
     return CatalogService(client=rpc_client)
 
 
-def get_job_service(
+def get_jobs_service(
     web_rest_api: Annotated[AuthSession, Depends(get_webserver_session)],
     web_rpc_api: Annotated[WbApiRpcClient, Depends(get_wb_api_rpc_client)],
     user_id: Annotated[UserID, Depends(get_current_user_id)],
     product_name: Annotated[ProductName, Depends(get_product_name)],
-) -> JobService:
+) -> JobsService:
     """
     "Assembles" the JobsService layer to the underlying service and client interfaces
     in the context of the rest controller (i.e. api/dependencies)
     """
-    return JobService(
+    return JobsService(
         web_rest_api=web_rest_api,
         web_rpc_api=web_rpc_api,
         user_id=user_id,
@@ -75,7 +75,7 @@ def get_job_service(
 
 def get_solver_service(
     catalog_service: Annotated[CatalogService, Depends(get_catalog_service)],
-    job_service: Annotated[JobService, Depends(get_job_service)],
+    jobs_service: Annotated[JobsService, Depends(get_jobs_service)],
 ) -> SolverService:
     """
     "Assembles" the SolverService layer to the underlying service and client interfaces
@@ -84,13 +84,13 @@ def get_solver_service(
 
     return SolverService(
         catalog_service=catalog_service,
-        job_service=job_service,
+        jobs_service=jobs_service,
     )
 
 
 def get_studies_service(
-    job_service: Annotated[JobService, Depends(get_job_service)],
+    jobs_service: Annotated[JobsService, Depends(get_jobs_service)],
 ) -> StudiesService:
     return StudiesService(
-        job_service=job_service,
+        jobs_service=jobs_service,
     )

services/api-server/src/simcore_service_api_server/api/routes/programs.py

@@ -19,7 +19,7 @@
     get_upload_links_from_s3,
 )
 
-from ..._service_job import JobService
+from ..._service_jobs import JobsService
 from ..._service_programs import ProgramService
 from ...api.routes._constants import (
     DEFAULT_MAX_STRING_LENGTH,
@@ -164,7 +164,7 @@ async def create_program_job(
     version: VersionStr,
     user_id: Annotated[PositiveInt, Depends(get_current_user_id)],
     program_service: Annotated[ProgramService, Depends()],
-    job_service: Annotated[JobService, Depends()],
+    jobs_service: Annotated[JobsService, Depends()],
     url_for: Annotated[Callable, Depends(get_reverse_url_mapper)],
     product_name: Annotated[str, Depends(get_product_name)],
     x_simcore_parent_project_uuid: Annotated[ProjectID | None, Header()] = None,
@@ -187,7 +187,7 @@ async def create_program_job(
         product_name=product_name,
     )
 
-    job, project = await job_service.create_job(
+    job, project = await jobs_service.create_job(
         project_name=name,
         description=description,
         solver_or_program=program,

services/api-server/src/simcore_service_api_server/api/routes/solvers_jobs.py

@@ -12,7 +12,7 @@
 from models_library.projects_nodes_io import NodeID
 from pydantic.types import PositiveInt
 
-from ..._service_job import JobService
+from ..._service_jobs import JobsService
 from ..._service_solvers import SolverService
 from ...exceptions.backend_errors import ProjectAlreadyStartedError
 from ...exceptions.service_errors_utils import DEFAULT_BACKEND_SERVICE_STATUS_CODES
@@ -92,7 +92,7 @@ async def create_solver_job(
     inputs: JobInputs,
     user_id: Annotated[PositiveInt, Depends(get_current_user_id)],
     solver_service: Annotated[SolverService, Depends(get_solver_service)],
-    job_service: Annotated[JobService, Depends()],
+    jobs_service: Annotated[JobsService, Depends()],
     url_for: Annotated[Callable, Depends(get_reverse_url_mapper)],
     product_name: Annotated[str, Depends(get_product_name)],
     hidden: Annotated[bool, Query()] = True,
@@ -111,7 +111,7 @@ async def create_solver_job(
         solver_version=version,
         product_name=product_name,
     )
-    job, _ = await job_service.create_job(
+    job, _ = await jobs_service.create_job(
         project_name=None,
         description=None,
         solver_or_program=solver,