Skip to content

Commit ef5a649

Browse files
committed
fixing
1 parent 2d5d5c3 commit ef5a649

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

services/director-v2/tests/unit/with_dbs/test_modules_comp_scheduler_dask_scheduler.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,9 @@
6666
from simcore_service_director_v2.models.comp_runs import CompRunsAtDB, RunMetadataDict
6767
from simcore_service_director_v2.models.comp_tasks import CompTaskAtDB, Image
6868
from simcore_service_director_v2.models.dask_subsystem import DaskClientTaskState
69-
from simcore_service_director_v2.modules.comp_scheduler._base_scheduler import (
69+
from simcore_service_director_v2.modules.comp_scheduler import (
7070
BaseCompScheduler,
71+
get_scheduler,
7172
)
7273
from simcore_service_director_v2.modules.comp_scheduler._dask_scheduler import (
7374
DaskScheduler,
@@ -262,7 +263,7 @@ async def test_scheduler_gracefully_starts_and_stops(
262263
minimal_app: FastAPI,
263264
):
264265
# check it started correctly
265-
assert minimal_app.state.computational_scheduler_task is not None
266+
assert get_scheduler(minimal_app) is not None
266267

267268

268269
@pytest.mark.parametrize(

0 commit comments

Comments
 (0)