fixed interface

Author: Andrei Neagu

services/director-v2/src/simcore_service_director_v2/api/routes/dynamic_scheduler.py

@@ -116,6 +116,7 @@ async def _progress_callback(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             _task_remove_service_containers.__name__,
             unique=True,
@@ -181,6 +182,7 @@ async def _progress_callback(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             _task_save_service_state.__name__,
             unique=True,
@@ -228,6 +230,7 @@ async def _progress_callback(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             _task_push_service_outputs.__name__,
             unique=True,
@@ -270,6 +273,7 @@ async def _task_cleanup_service_docker_resources(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             _task_cleanup_service_docker_resources.__name__,
             unique=True,

services/director-v2/src/simcore_service_director_v2/modules/dynamic_sidecar/module_setup.py

@@ -1,11 +1,13 @@
 from fastapi import FastAPI
 from servicelib.fastapi import long_running_tasks
+from servicelib.long_running_tasks.models import RabbitNamespace
 from servicelib.long_running_tasks.task import RedisNamespace
 
 from ...core.settings import AppSettings
 from . import api_client, scheduler
 
-_LONG_RUNNING_TASKS_NAMESPACE: RedisNamespace = "director-v2"
+_LRT_REDIS_NAMESPACE: RedisNamespace = "director-v2"
+_LRT_RABBIT_NAMESPACE: RabbitNamespace = "director-v2"
 
 
 def setup(app: FastAPI) -> None:
@@ -15,7 +17,9 @@ def setup(app: FastAPI) -> None:
     long_running_tasks.server.setup(
         app,
         redis_settings=settings.REDIS,
-        redis_namespace=_LONG_RUNNING_TASKS_NAMESPACE,
+        redis_namespace=_LRT_REDIS_NAMESPACE,
+        rabbit_settings=settings.DIRECTOR_V2_RABBITMQ,
+        rabbit_namespace=_LRT_RABBIT_NAMESPACE,
     )
 
     async def on_startup() -> None: