File tree Expand file tree Collapse file tree 4 files changed +5
-12
lines changed
src/simcore_service_catalog/api/rest
src/simcore_service_director_v2/modules
tests/unit/with_dbs/comp_scheduler Expand file tree Collapse file tree 4 files changed +5
-12
lines changed Original file line number Diff line number Diff line change 11from typing import Annotated , Any
22
33from fastapi import APIRouter , Depends
4- from models_library .generics import Envelope
54from models_library .services import ServiceKey , ServiceVersion
65
76from ...services .director import DirectorApi
@@ -16,7 +15,4 @@ async def get_service_extras(
1615 service_version : ServiceVersion ,
1716 director_client : Annotated [DirectorApi , Depends (get_director_api )],
1817) -> dict [str , Any ]:
19- service_extras = await director_client .get_service_extras (
20- service_key , service_version
21- )
22- return Envelope [dict [str , Any ]](data = service_extras ).model_dump (mode = "json" )
18+ return await director_client .get_service_extras (service_key , service_version )
Original file line number Diff line number Diff line change @@ -15,7 +15,7 @@ def mock_engine(app: FastAPI) -> None:
1515 app .state .engine = AsyncMock ()
1616
1717
18- async def test_get_service_labels (
18+ async def test_get_service_extras (
1919 postgres_setup_disabled : None ,
2020 mocked_director_service_api : MockRouter ,
2121 rabbitmq_and_rpc_setup_disabled : None ,
@@ -28,4 +28,4 @@ async def test_get_service_labels(
2828 service_version = "3.0.0"
2929 result = await aclient .get (f"/v0/services/{ service_key } /{ service_version } /extras" )
3030 assert result .status_code == status .HTTP_200_OK , result .text
31- assert result .json () == { "data" : mock_service_extras , "error" : None }
31+ assert result .json () == mock_service_extras
Original file line number Diff line number Diff line change 1616from settings_library .tracing import TracingSettings
1717
1818from ..utils .client_decorators import handle_errors , handle_retry
19- from ..utils .clients import unenvelope_or_raise_error
2019
2120logger = logging .getLogger (__name__ )
2221
@@ -130,7 +129,7 @@ async def get_service_extras(
130129 f"/services/{ urllib .parse .quote_plus (service_key )} /{ service_version } /extras" ,
131130 )
132131 if resp .status_code == status .HTTP_200_OK :
133- return ServiceExtras .model_validate (unenvelope_or_raise_error ( resp ) )
132+ return ServiceExtras .model_validate (resp )
134133 raise HTTPException (status_code = resp .status_code , detail = resp .content )
135134
136135 async def get_service_specifications (
Original file line number Diff line number Diff line change @@ -219,9 +219,7 @@ def _mocked_services_details(
219219 r"/services/simcore%2Fservices%2F(comp|dynamic|frontend)%2F[^/]+/\d+.\d+.\d+/extras"
220220 ),
221221 name = "get_service_extras" ,
222- ).respond (
223- json = {"data" : fake_service_extras .model_dump (mode = "json" , by_alias = True )}
224- )
222+ ).respond (json = fake_service_extras .model_dump (mode = "json" , by_alias = True ))
225223 respx_mock .get (
226224 re .compile (
227225 r"services/(?P<service_key>simcore%2Fservices%2F(comp|dynamic|frontend)%2F[^/]+)/(?P<service_version>[^\.]+.[^\.]+.[^/\?]+).*"
You can’t perform that action at this time.
0 commit comments