Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 1 addition & 6 deletions src/dvc_task/proc/process.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand All @@ -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."""
Expand Down