fixed interfaces

Author: Andrei Neagu

services/dynamic-sidecar/src/simcore_service_dynamic_sidecar/api/rest/containers_long_running_tasks.py

@@ -59,6 +59,7 @@ async def pull_user_servcices_docker_images(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_pull_user_servcices_docker_images.__name__,
             unique=True,
@@ -100,6 +101,7 @@ async def create_service_containers_task(  # pylint: disable=too-many-arguments
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_create_service_containers.__name__,
             unique=True,
@@ -134,6 +136,7 @@ async def runs_docker_compose_down_task(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_runs_docker_compose_down.__name__,
             unique=True,
@@ -166,6 +169,7 @@ async def state_restore_task(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_restore_state.__name__,
             unique=True,
@@ -197,6 +201,7 @@ async def state_save_task(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_save_state.__name__,
             unique=True,
@@ -230,6 +235,7 @@ async def ports_inputs_pull_task(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_ports_inputs_pull.__name__,
             unique=True,
@@ -263,6 +269,7 @@ async def ports_outputs_pull_task(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_ports_outputs_pull.__name__,
             unique=True,
@@ -293,6 +300,7 @@ async def ports_outputs_push_task(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_ports_outputs_push.__name__,
             unique=True,
@@ -323,6 +331,7 @@ async def containers_restart_task(
 
     try:
         return await lrt_api.start_task(
+            long_running_manager.rpc_client,
             long_running_manager,
             task_containers_restart.__name__,
             unique=True,

services/dynamic-sidecar/src/simcore_service_dynamic_sidecar/core/application.py

@@ -150,6 +150,8 @@ def create_base_app() -> FastAPI:
         app,
         redis_settings=app_settings.REDIS_SETTINGS,
         redis_namespace=f"dy_sidecar-{app_settings.DY_SIDECAR_RUN_ID}",
+        rabbit_settings=app_settings.RABBIT_SETTINGS,
+        rabbit_namespace=f"dy_sidecar-{app_settings.DY_SIDECAR_RUN_ID}",
     )
 
     app.include_router(get_main_router(app))