diff --git a/src/dvc_task/proc/process.py b/src/dvc_task/proc/process.py index 7564cf6..5f20f23 100644 --- a/src/dvc_task/proc/process.py +++ b/src/dvc_task/proc/process.py @@ -13,7 +13,6 @@ from funcy import cached_property from shortuuid import uuid -from ..contrib.kombu_filesystem import LOCK_SH, lock, unlock from ..utils import makedirs from .exceptions import TimeoutExpired @@ -39,11 +38,7 @@ def from_dict(cls, data: Dict[str, Any]) -> "ProcessInfo": def load(cls, filename: str) -> "ProcessInfo": """Construct the process information from a file.""" with open(filename, encoding="utf-8") as fobj: - lock(fobj, LOCK_SH) - try: - return cls.from_dict(json.load(fobj)) - finally: - unlock(fobj) + return cls.from_dict(json.load(fobj)) def asdict(self) -> Dict[str, Any]: """Return this info as a dictionary."""