Skip to content

Commit 45b8767

Browse files
committed
@bisgaard-itis review: url jobs moved
1 parent 618a2c7 commit 45b8767

File tree

2 files changed

+33
-34
lines changed

2 files changed

+33
-34
lines changed

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

Lines changed: 32 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
from models_library.projects_nodes_io import BaseFileLink
1515
from models_library.users import UserID
1616
from models_library.wallets import ZERO_CREDITS
17-
from pydantic import NonNegativeInt
17+
from pydantic import HttpUrl, NonNegativeInt
1818
from pydantic.types import PositiveInt
1919
from servicelib.fastapi.requests_decorators import cancel_on_disconnect
2020
from servicelib.logging_utils import log_context
@@ -36,7 +36,6 @@
3636
JobLog,
3737
JobMetadata,
3838
JobOutputs,
39-
update_job_urls,
4039
)
4140
from ...models.schemas.model_adapter import (
4241
PricingUnitGetLegacy,
@@ -119,6 +118,36 @@
119118
}
120119

121120

121+
def _update_job_urls(
122+
job: Job,
123+
solver_key: SolverKeyId,
124+
solver_version: VersionStr,
125+
job_id: JobID | str,
126+
url_for: Callable[..., HttpUrl],
127+
) -> Job:
128+
job.url = url_for(
129+
"get_job",
130+
solver_key=solver_key,
131+
version=solver_version,
132+
job_id=job_id,
133+
)
134+
135+
job.runner_url = url_for(
136+
"get_solver_release",
137+
solver_key=solver_key,
138+
version=solver_version,
139+
)
140+
141+
job.outputs_url = url_for(
142+
"get_job_outputs",
143+
solver_key=solver_key,
144+
version=solver_version,
145+
job_id=job_id,
146+
)
147+
148+
return job
149+
150+
122151
router = APIRouter()
123152

124153

@@ -150,7 +179,7 @@ async def list_all_solvers_jobs(
150179

151180
for job in jobs:
152181
solver_key, version, job_id = parse_resources_ids(job.resource_name)
153-
update_job_urls(job, solver_key, version, job_id, url_for)
182+
_update_job_urls(job, solver_key, version, job_id, url_for)
154183

155184
return create_page(
156185
jobs,

services/api-server/src/simcore_service_api_server/models/schemas/jobs.py

Lines changed: 1 addition & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@
4848
# - custom metadata
4949
#
5050
from .programs import Program, ProgramKeyId
51-
from .solvers import Solver, SolverKeyId
51+
from .solvers import Solver
5252

5353
JobID: TypeAlias = UUID
5454

@@ -362,36 +362,6 @@ def get_outputs_url(
362362
return None
363363

364364

365-
def update_job_urls(
366-
job: Job,
367-
solver_key: SolverKeyId,
368-
solver_version: VersionStr,
369-
job_id: JobID | str,
370-
url_for: Callable[..., HttpUrl],
371-
) -> Job:
372-
job.url = url_for(
373-
"get_job",
374-
solver_key=solver_key,
375-
version=solver_version,
376-
job_id=job_id,
377-
)
378-
379-
job.runner_url = url_for(
380-
"get_solver_release",
381-
solver_key=solver_key,
382-
version=solver_version,
383-
)
384-
385-
job.outputs_url = url_for(
386-
"get_job_outputs",
387-
solver_key=solver_key,
388-
version=solver_version,
389-
job_id=job_id,
390-
)
391-
392-
return job
393-
394-
395365
PercentageInt: TypeAlias = Annotated[int, Field(ge=0, le=100)]
396366

397367

0 commit comments

Comments
 (0)