diff --git a/kgforge/core/commons/execution.py b/kgforge/core/commons/execution.py index a4483b38..e7f117c1 100644 --- a/kgforge/core/commons/execution.py +++ b/kgforge/core/commons/execution.py @@ -155,7 +155,7 @@ def _run_one(fun: Callable, resource: Resource, exception: Type[RunException], i if monitored_status: setattr(resource, monitored_status, status) - resource.set_last_action(Action(fun.__name__, succeeded, exception)) + resource._last_action = Action(fun.__name__, succeeded, exception) if not catch_exceptions and exception: raise exception diff --git a/kgforge/core/resource.py b/kgforge/core/resource.py index a9c7043f..f3f405e4 100644 --- a/kgforge/core/resource.py +++ b/kgforge/core/resource.py @@ -85,11 +85,6 @@ def _sync_resource(item, vlist, sync_value=True): else: vlist.append(item) - def set_validated(self, validation_status: bool): - self._validated = validation_status - - def set_last_action(self, action: "Action"): - self._last_action = action def _get_synchronized(self) -> bool: inner = [] diff --git a/kgforge/specializations/models/rdf_model.py b/kgforge/specializations/models/rdf_model.py index 9ad14f63..0021389a 100644 --- a/kgforge/specializations/models/rdf_model.py +++ b/kgforge/specializations/models/rdf_model.py @@ -114,16 +114,16 @@ def _validate_many(self, resources: List[Resource], type_: str) -> None: for resource in resources: conforms, graph, _ = self.service.validate(resource, type_=type_) if conforms: - resource.set_validated(True) + resource._validated = True action = Action(self._validate_many.__name__, conforms, None) else: - resource.set_validated(False) + resource._validated = False violations = set(" ".join(re.findall('[A-Z][^A-Z]*', as_term(o))) for o in graph.objects(None, SH.sourceConstraintComponent)) message = f"violation(s) of type(s) {', '.join(sorted(violations))}" action = Action(self._validate_many.__name__, conforms, ValidationError(message)) - resource.set_last_action(action) + resource._last_action = action def _validate_one(self, resource: Resource, type_: str) -> None: conforms, _, report = self.service.validate(resource, type_) diff --git a/kgforge/specializations/stores/nexus/service.py b/kgforge/specializations/stores/nexus/service.py index 46248031..53719aea 100644 --- a/kgforge/specializations/stores/nexus/service.py +++ b/kgforge/specializations/stores/nexus/service.py @@ -491,7 +491,7 @@ def synchronize_resource( else: action = Action(action_name, succeeded, response) - resource.set_last_action(action) + resource._last_action = action resource._synchronized = synchronized def default_callback(self, fun_name: str) -> Callable: