diff --git a/pyproject.toml b/pyproject.toml index 330f608..fa53c02 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -17,7 +17,7 @@ classifiers = [ requires-python = ">=3.8" dependencies = [ "ewokscore >=5.0.0", - "pypushflow >=2.0.0", + "pypushflow >2.0.0", ] [project.urls] diff --git a/src/ewoksppf/bindings.py b/src/ewoksppf/bindings.py index a6f454d..66a9298 100644 --- a/src/ewoksppf/bindings.py +++ b/src/ewoksppf/bindings.py @@ -154,9 +154,7 @@ def _conditions_fulfilled(self, inData: dict) -> bool: return True def _execute(self, inData: dict, _scope_id: Optional[str] = None) -> None: - self.setStarted() trigger = self._conditions_fulfilled(inData) - self.setFinished() if trigger: for actor in self.listDownStreamActor: actor.trigger(inData) @@ -263,11 +261,7 @@ def _execute( source: Optional[AbstractActor] = None, ) -> None: with self._lock: - self.setStarted() - try: - self._cache_inputs(source, inData) - finally: - self.setFinished() + self._cache_inputs(source, inData) if not self._has_all_required_triggers(): return