start interface

Author: pcrespov

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

@@ -12,6 +12,10 @@
 from models_library.projects import ProjectID
 from models_library.projects_nodes_io import NodeID
 from pydantic.types import PositiveInt
+from simcore_service_api_server.api.dependencies.webserver_rpc import (
+    get_wb_api_rpc_client,
+)
+from simcore_service_api_server.services_rpc.wb_api_server import WbApiRpcClient
 
 from ...exceptions.backend_errors import ProjectAlreadyStartedError
 from ...exceptions.service_errors_utils import DEFAULT_BACKEND_SERVICE_STATUS_CODES
@@ -95,6 +99,7 @@ async def create_job(
     user_id: Annotated[PositiveInt, Depends(get_current_user_id)],
     catalog_client: Annotated[CatalogApi, Depends(get_api_client(CatalogApi))],
     webserver_api: Annotated[AuthSession, Depends(get_webserver_session)],
+    wb_api_rpc: Annotated[WbApiRpcClient, Depends(get_wb_api_rpc_client)],
     url_for: Annotated[Callable, Depends(get_reverse_url_mapper)],
     product_name: Annotated[str, Depends(get_product_name)],
     hidden: Annotated[bool, Query()] = True,
@@ -126,6 +131,7 @@ async def create_job(
         parent_project_uuid=x_simcore_parent_project_uuid,
         parent_node_id=x_simcore_parent_node_id,
     )
+
     assert new_project  # nosec
     assert new_project.uuid == pre_job.id  # nosec
 
@@ -140,6 +146,10 @@ async def create_job(
     assert job.name == pre_job.name  # nosec
     assert job.name == _compose_job_resource_name(solver_key, version, job.id)  # nosec
 
+    await wb_api_rpc.mark_project_as_job(
+        project_uuid=new_project.uuid, job_parent_resource_name=job.runner_name
+    )
+
     return job
 
 

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

@@ -15,6 +15,10 @@
 from models_library.projects_nodes_io import NodeID
 from pydantic import PositiveInt
 from servicelib.logging_utils import log_context
+from simcore_service_api_server.api.dependencies.webserver_rpc import (
+    get_wb_api_rpc_client,
+)
+from simcore_service_api_server.services_rpc.wb_api_server import WbApiRpcClient
 
 from ...api.dependencies.authentication import get_current_user_id
 from ...api.dependencies.services import get_api_client
@@ -86,6 +90,7 @@ async def create_study_job(
     study_id: StudyID,
     job_inputs: JobInputs,
     webserver_api: Annotated[AuthSession, Depends(get_webserver_session)],
+    wb_api_rpc: Annotated[WbApiRpcClient, Depends(get_wb_api_rpc_client)],
     url_for: Annotated[Callable, Depends(get_reverse_url_mapper)],
     hidden: Annotated[bool, Query()] = True,
     x_simcore_parent_project_uuid: ProjectID | None = Header(default=None),
@@ -94,14 +99,11 @@ async def create_study_job(
     """
     hidden -- if True (default) hides project from UI
     """
-    study_name = Study.compose_resource_name(f"{study_id}")
-
     project = await webserver_api.clone_project(
         project_id=study_id,
         hidden=hidden,
         parent_project_uuid=x_simcore_parent_project_uuid,
         parent_node_id=x_simcore_parent_node_id,
-        job_parent_resource_name=study_name,
     )
     job = create_job_from_study(
         study_key=study_id, project=project, job_inputs=job_inputs
@@ -123,6 +125,10 @@ async def create_study_job(
         patch_params=ProjectPatch(name=job.name),  # type: ignore[arg-type]
     )
 
+    await wb_api_rpc.mark_project_as_job(
+        project_uuid=job.id, job_parent_resource_name=job.runner_name
+    )
+
     project_inputs = await webserver_api.get_project_inputs(project_id=project.uuid)
 
     file_param_nodes = {}

services/api-server/src/simcore_service_api_server/services_rpc/wb_api_server.py

@@ -6,6 +6,7 @@
 from fastapi_pagination import create_page
 from models_library.api_schemas_webserver.licensed_items import LicensedItemRpcGetPage
 from models_library.licenses import LicensedItemID
+from models_library.projects import ProjectID
 from models_library.resource_tracker_licensed_items_checkouts import (
     LicensedItemCheckoutID,
 )
@@ -41,6 +42,7 @@
 from servicelib.rabbitmq.rpc_interfaces.webserver.licenses.licensed_items import (
     release_licensed_item_for_wallet as _release_licensed_item_for_wallet,
 )
+from simcore_service_api_server.models.api_resources import RelativeResourceName
 
 from ..exceptions.backend_errors import (
     CanNotCheckoutServiceIsNotRunningError,
@@ -200,6 +202,17 @@ async def release_licensed_item_for_wallet(
     async def ping(self) -> str:
         return await _ping(self._client)
 
+    async def mark_project_as_job(
+        self, project_uuid: ProjectID, job_parent_resource_name: RelativeResourceName
+    ):
+        assert not job_parent_resource_name.startswith("/")  # nosec
+        assert "/" in job_parent_resource_name  # nosec
+        assert not job_parent_resource_name.endswith("/")  # nosec
+
+        assert project_uuid
+
+        raise NotImplementedError
+
 
 def setup(app: FastAPI, rabbitmq_rmp_client: RabbitMQRPCClient):
     wb_api_rpc_client = WbApiRpcClient(_client=rabbitmq_rmp_client)