pino/sillyhome-next
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 47 Wiki Activity

BEHAVIOR-002: isolate per-actuator runtime failures
Some checks failed
quality / test (3.11) (push) Has been cancelled
Details
quality / test (3.13) (push) Has been cancelled
Details
quality / test (3.11) (pull_request) Has been cancelled
Details
quality / test (3.13) (pull_request) Has been cancelled
Details

Browse Source
This commit is contained in:
Otto
2026-06-14 10:40:19 +02:00
parent b215f23dd9
commit da4603be17
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
app/behavior/engine.py
View File

@@ -41,7 +41,14 @@ class BehaviorEngine:
self._settings = settings self._settings = settings
def train_all(self) -> list[ActuatorRecord]: def train_all(self) -> list[ActuatorRecord]:
return [self.train(record.actuator_entity_id) for record in self._store.list()] results: list[ActuatorRecord] = []
for record in self._store.list():
try:
results.append(self.train(record.actuator_entity_id))
except Exception:
logger.exception("Behavior training failed for %s", record.actuator_entity_id)
results.append(record)
return results
def train(self, actuator_entity_id: str) -> ActuatorRecord: def train(self, actuator_entity_id: str) -> ActuatorRecord:
record = self._store.get(actuator_entity_id) record = self._store.get(actuator_entity_id)
@@ -143,7 +150,14 @@ class BehaviorEngine:
return self._save_behavior(record, behavior) return self._save_behavior(record, behavior)
def evaluate_all(self) -> list[ActuatorRecord]: def evaluate_all(self) -> list[ActuatorRecord]:
return [self.evaluate(record.actuator_entity_id) for record in self._store.list()] results: list[ActuatorRecord] = []
for record in self._store.list():
try:
results.append(self.evaluate(record.actuator_entity_id))
except Exception:
logger.exception("Behavior evaluation failed for %s", record.actuator_entity_id)
results.append(record)
return results
def evaluate(self, actuator_entity_id: str) -> ActuatorRecord: def evaluate(self, actuator_entity_id: str) -> ActuatorRecord:
record = self._store.get(actuator_entity_id) record = self._store.get(actuator_entity_id)