diff --git a/services/api-server/src/simcore_service_api_server/api/routes/solvers_jobs.py b/services/api-server/src/simcore_service_api_server/api/routes/solvers_jobs.py index d9bb3d609ee..8930d3a6789 100644 --- a/services/api-server/src/simcore_service_api_server/api/routes/solvers_jobs.py +++ b/services/api-server/src/simcore_service_api_server/api/routes/solvers_jobs.py @@ -145,7 +145,9 @@ async def create_job( # -> director2: ComputationTaskOut = JobStatus # consistency check - task: ComputationTaskGet = await director2_api.create_computation(job.id, user_id) + task: ComputationTaskGet = await director2_api.create_computation( + job.id, user_id, product_name + ) assert task.id == job.id # nosec job_status: JobStatus = create_jobstatus_from_task(task) diff --git a/services/api-server/src/simcore_service_api_server/modules/director_v2.py b/services/api-server/src/simcore_service_api_server/modules/director_v2.py index 636c0a067b9..21426b4be53 100644 --- a/services/api-server/src/simcore_service_api_server/modules/director_v2.py +++ b/services/api-server/src/simcore_service_api_server/modules/director_v2.py @@ -102,7 +102,10 @@ class DirectorV2Api(BaseServiceClientApi): # ServiceUnabalabe: 503 async def create_computation( - self, project_id: UUID, user_id: PositiveInt + self, + project_id: UUID, + user_id: PositiveInt, + product_name: str, ) -> ComputationTaskGet: resp = await self.client.post( "/v2/computations", @@ -110,6 +113,7 @@ async def create_computation( "user_id": user_id, "project_id": str(project_id), "start_pipeline": False, + "product_name": product_name, }, )