reverted

Author: Andrei Neagu

packages/service-library/tests/deferred_tasks/test_deferred_tasks.py

@@ -32,6 +32,7 @@
 
 pytest_simcore_core_services_selection = [
     "rabbit",
+    "redis",
 ]
 pytest_simcore_ops_services_selection = [
     "redis-commander",
@@ -135,12 +136,12 @@ def __init__(
         self,
         remote_process: _RemoteProcess,
         rabbit_service: RabbitSettings,
-        redis_settings: RedisSettings,
+        redis_service: RedisSettings,
         max_workers: int,
     ) -> None:
         self.remote_process = remote_process
         self.rabbit_service = rabbit_service
-        self.redis_settings = redis_settings
+        self.redis_service = redis_service
         self.max_workers = max_workers
 
     async def __aenter__(self) -> "_RemoteProcessLifecycleManager":
@@ -167,7 +168,7 @@ async def start(self) -> None:
                 ),
                 "redis": json_dumps(
                     model_dump_with_secrets(
-                        self.redis_settings,
+                        self.redis_service,
                         show_secrets=True,
                         **_get_serialization_options(),
                     )
@@ -255,7 +256,7 @@ async def _sleep_in_interval(lower: NonNegativeFloat, upper: NonNegativeFloat) -
 async def test_workflow_with_outages_in_process_running_deferred_manager(
     get_remote_process: Callable[[], Awaitable[_RemoteProcess]],
     rabbit_service: RabbitSettings,
-    use_in_memory_redis: RedisSettings,
+    redis_service: RedisSettings,
     remote_processes: int,
     max_workers: int,
     deferred_tasks_to_start: NonNegativeInt,
@@ -268,7 +269,7 @@ async def test_workflow_with_outages_in_process_running_deferred_manager(
                     _RemoteProcessLifecycleManager(
                         await get_remote_process(),
                         rabbit_service,
-                        use_in_memory_redis,
+                        redis_service,
                         max_workers,
                     )
                 )
@@ -402,7 +403,7 @@ async def test_workflow_with_third_party_services_outages(
     rabbit_client: RabbitMQClient,
     get_remote_process: Callable[[], Awaitable[_RemoteProcess]],
     rabbit_service: RabbitSettings,
-    use_in_memory_redis: RedisSettings,
+    redis_service: RedisSettings,
     max_workers: int,
     deferred_tasks_to_start: int,
     service: str,
@@ -414,7 +415,7 @@ async def test_workflow_with_third_party_services_outages(
     async with _RemoteProcessLifecycleManager(
         await get_remote_process(),
         rabbit_service,
-        use_in_memory_redis,
+        redis_service,
         max_workers,
     ) as manager:
         # start all in parallel