Skip to content

Commit d426f7c

Browse files
author
Andrei Neagu
committed
refactor
1 parent 2354e68 commit d426f7c

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

services/agent/src/simcore_service_agent/services/containers_manager.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
)
1010
from models_library.projects_nodes_io import NodeID
1111
from servicelib.fastapi.app_state import SingletonInAppStateMixin
12-
from servicelib.utils import limited_gather
1312

1413
from ..core.settings import ApplicationSettings
1514
from .docker_utils import get_containers_with_prefixes, remove_container_forcefully
@@ -51,12 +50,9 @@ async def force_container_cleanup(self, node_id: NodeID) -> None:
5150
unexpected_orphans,
5251
)
5352

54-
await limited_gather(
55-
*[
56-
remove_container_forcefully(self.docker, container)
57-
for container in orphan_containers
58-
],
59-
)
53+
# avoids parallel requests to docker engine
54+
for container in orphan_containers:
55+
await remove_container_forcefully(self.docker, container)
6056

6157
async def shutdown(self) -> None:
6258
await self.docker.close()

0 commit comments

Comments
 (0)