logs fetching is resumed and restarted each time the service is reloaded (ITISFoundation#2822)

Co-authored-by: Andrei Neagu <[email protected]>
Co-authored-by: Pedro Crespo-Valero <[email protected]>

Author: 3 people

services/dynamic-sidecar/src/simcore_service_dynamic_sidecar/api/containers.py

@@ -525,6 +525,7 @@ async def restarts_containers(
     command_timeout: float = Query(
         10.0, description="docker-compose stop command timeout default"
     ),
+    app: FastAPI = Depends(get_application),
     settings: DynamicSidecarSettings = Depends(get_settings),
     shared_store: SharedStore = Depends(get_shared_store),
     rabbitmq: RabbitMQ = Depends(get_rabbitmq),
@@ -539,6 +540,9 @@ async def restarts_containers(
             detail="No spec for docker-compose command was found",
         )
 
+    for container_name in shared_store.container_names:
+        await stop_log_fetching(app, container_name)
+
     command = (
         "docker-compose --project-name {project} --file {file_path} "
         "restart --timeout {stop_and_remove_timeout}"
@@ -555,6 +559,9 @@ async def restarts_containers(
         logger.warning(error_message)
         raise HTTPException(status.HTTP_422_UNPROCESSABLE_ENTITY, detail=stdout)
 
+    for container_name in shared_store.container_names:
+        await start_log_fetching(app, container_name)
+
     await _send_message(rabbitmq, "Service was restarted please reload the UI")
     await rabbitmq.send_event_reload_iframe()