| 
6 | 6 | import json  | 
7 | 7 | from collections.abc import AsyncIterable, AsyncIterator, Awaitable, Callable, Iterator  | 
8 | 8 | from contextlib import asynccontextmanager, contextmanager  | 
9 |  | -from inspect import getmembers, isfunction  | 
10 | 9 | from pathlib import Path  | 
11 | 10 | from typing import Any, Final, NamedTuple  | 
12 | 11 | from unittest.mock import AsyncMock  | 
 | 
45 | 44 | from settings_library.rabbit import RabbitSettings  | 
46 | 45 | from simcore_sdk.node_ports_common.exceptions import NodeNotFound  | 
47 | 46 | from simcore_service_dynamic_sidecar._meta import API_VTAG  | 
48 |  | -from simcore_service_dynamic_sidecar.api.rest import containers_long_running_tasks  | 
49 | 47 | from simcore_service_dynamic_sidecar.core.validation import InvalidComposeSpecError  | 
50 | 48 | from simcore_service_dynamic_sidecar.models.shared_store import SharedStore  | 
 | 49 | +from simcore_service_dynamic_sidecar.modules import long_running_tasks as sidecar_lrts  | 
51 | 50 | from simcore_service_dynamic_sidecar.modules.inputs import enable_inputs_pulling  | 
52 | 51 | from simcore_service_dynamic_sidecar.modules.outputs._context import OutputsContext  | 
53 | 52 | from simcore_service_dynamic_sidecar.modules.outputs._manager import OutputsManager  | 
@@ -92,17 +91,18 @@ async def _just_log_task(*args, **kwargs) -> None:  | 
92 | 91 | 
 
  | 
93 | 92 |     TaskRegistry.register(_just_log_task)  | 
94 | 93 | 
 
  | 
95 |  | -    # searching by name since all start with _task  | 
96 |  | -    tasks_names = [  | 
97 |  | -        x[0]  | 
98 |  | -        for x in getmembers(containers_long_running_tasks, isfunction)  | 
99 |  | -        if x[0].startswith("task")  | 
100 |  | -    ]  | 
101 |  | - | 
102 |  | -    for task_name in tasks_names:  | 
103 |  | -        mocker.patch.object(  | 
104 |  | -            containers_long_running_tasks, task_name, new=_just_log_task  | 
105 |  | -        )  | 
 | 94 | +    for task_name in [  | 
 | 95 | +        sidecar_lrts.task_pull_user_servcices_docker_images.__name__,  | 
 | 96 | +        sidecar_lrts.task_create_service_containers.__name__,  | 
 | 97 | +        sidecar_lrts.task_runs_docker_compose_down.__name__,  | 
 | 98 | +        sidecar_lrts.task_restore_state.__name__,  | 
 | 99 | +        sidecar_lrts.task_save_state.__name__,  | 
 | 100 | +        sidecar_lrts.task_ports_inputs_pull.__name__,  | 
 | 101 | +        sidecar_lrts.task_ports_outputs_pull.__name__,  | 
 | 102 | +        sidecar_lrts.task_ports_outputs_push.__name__,  | 
 | 103 | +        sidecar_lrts.task_containers_restart.__name__,  | 
 | 104 | +    ]:  | 
 | 105 | +        mocker.patch.object(sidecar_lrts, task_name, new=_just_log_task)  | 
106 | 106 | 
 
  | 
107 | 107 |     yield None  | 
108 | 108 | 
 
  | 
 | 
0 commit comments