11
11
12
12
import pytest
13
13
from fastapi import FastAPI
14
+ from models_library .services_metadata_published import ServiceMetaDataPublished
14
15
from pytest_simcore .helpers .monkeypatch_envs import setenvs_from_dict
15
16
from pytest_simcore .helpers .typing_env import EnvVarsDict
16
17
from respx .router import MockRouter
@@ -35,6 +36,7 @@ def app_environment(
35
36
async def test_director_client_high_level_api (
36
37
background_tasks_setup_disabled : None ,
37
38
rabbitmq_and_rpc_setup_disabled : None ,
39
+ expected_director_list_services : list [dict [str , Any ]],
38
40
mocked_director_service_api : MockRouter ,
39
41
app : FastAPI ,
40
42
):
@@ -47,20 +49,13 @@ async def test_director_client_high_level_api(
47
49
# PING
48
50
assert await director_api .is_responsive ()
49
51
50
- # LIST
51
- all_services = await director_api .list_all_services ()
52
- assert mocked_director_service_api ["list_services" ].called
53
-
54
- services_image_digest = {service .image_digest for service in all_services }
55
- assert None not in services_image_digest
56
- assert len (services_image_digest ) == len (all_services )
57
-
58
52
# GET
59
- expected_service = all_services [0 ]
53
+ expected_service = ServiceMetaDataPublished ( ** expected_director_list_services [0 ])
60
54
assert (
61
55
await director_api .get_service (expected_service .key , expected_service .version )
62
56
== expected_service
63
57
)
58
+ # TODO: error handling!
64
59
65
60
66
61
async def test_director_client_low_level_api (
0 commit comments