From 426bdc721e8da7fd2d2d9de64e4f8e3207e53cd4 Mon Sep 17 00:00:00 2001 From: David Conner Date: Mon, 22 Jul 2024 12:25:30 -0400 Subject: [PATCH] update get_required_autonomy check for concurrency container --- flexbe_core/flexbe_core/core/concurrency_container.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/flexbe_core/flexbe_core/core/concurrency_container.py b/flexbe_core/flexbe_core/core/concurrency_container.py index cc3aa61..d198356 100644 --- a/flexbe_core/flexbe_core/core/concurrency_container.py +++ b/flexbe_core/flexbe_core/core/concurrency_container.py @@ -83,13 +83,14 @@ def current_state_label(self): def get_required_autonomy(self, outcome, state): """Return required autonomy level for this outcome.""" try: - assert state in self._current_state, "get required autonomy in ConcurrencyContainer - state doesn't match!" + assert state in self._states, "get required autonomy in ConcurrencyContainer - state doesn't match!" return self._autonomy[state.name][outcome] except Exception as exc: Logger.error(f"Failure to retrieve autonomy for '{self.name}' in CC - " f" current state label='{self.name}' state='{state.name}' outcome='{outcome}'.") - Logger.localerr(f'{type(exc)} - {exc}\n\n {self._current_state}') - Logger.localerr(f'{self._autonomy}') + Logger.localerr(f'error={type(exc)} - {exc}') + Logger.localerr(f'current_state={self._current_state}') + Logger.localerr(f'autonomy={self._autonomy}') def _execute_current_state(self): """Execute the current states within this concurrency container.""" @@ -132,6 +133,7 @@ def _execute_current_state(self): for state in self._states: if state.name in self._returned_outcomes and self._returned_outcomes[state.name] is not None: # print(f" in current {self._name} : state '{state.name}' is already done.", flush=True) + self._current_state.append(state) continue # already done with executing if self._manual_transition_requested is not None: