Skip to content

Commit 0c476e1

Browse files
reuse remove_directory function
1 parent 38f9489 commit 0c476e1

File tree

1 file changed

+2
-4
lines changed
  • services/efs-guardian/src/simcore_service_efs_guardian/services

1 file changed

+2
-4
lines changed

services/efs-guardian/src/simcore_service_efs_guardian/services/efs_manager.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,13 @@
1-
import asyncio
21
import logging
32
import os
4-
import shutil
53
from dataclasses import dataclass
64
from pathlib import Path
75

86
from fastapi import FastAPI
97
from models_library.projects import ProjectID
108
from models_library.projects_nodes_io import NodeID
119
from pydantic import ByteSize, TypeAdapter, ValidationError
10+
from servicelib.file_utils import remove_directory
1211

1312
from ..core.settings import ApplicationSettings, get_application_settings
1413
from . import efs_manager_utils
@@ -154,8 +153,7 @@ async def remove_project_efs_data(self, project_id: ProjectID) -> None:
154153
if Path.exists(_dir_path):
155154
# Remove the directory and all its contents
156155
try:
157-
loop = asyncio.get_event_loop()
158-
await loop.run_in_executor(None, shutil.rmtree, _dir_path)
156+
await remove_directory(_dir_path)
159157
_logger.info("%s has been deleted.", _dir_path)
160158
except FileNotFoundError:
161159
_logger.exception("Directory %s does not exist.", _dir_path)

0 commit comments

Comments
 (0)