ITQC/pydase
24
0
Fork 0
mirror of https://github.com/tiqi-group/pydase.git synced 2025-06-06 13:30:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

adds warnings if types change in cache

Browse Source
This commit is contained in:
Mose Müller 2023-12-05 10:12:00 +01:00
parent e48a7067ec
commit 44cd9597cb
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/pydase/data_service/data_service_observer.py
View File

@ -42,7 +42,7 @@ class DataServiceObserver(Observer):
if cached_value != value: if cached_value != value:
logger.debug("'%s' changed to '%s'", full_access_path, value) logger.debug("'%s' changed to '%s'", full_access_path, value)
self._update_cache_value(full_access_path, cached_value_dict, value) self._update_cache_value(full_access_path, value, cached_value_dict)
for callback in self._notification_callbacks: for callback in self._notification_callbacks:
callback(full_access_path, value, cached_value_dict) callback(full_access_path, value, cached_value_dict)
@ -50,9 +50,19 @@ class DataServiceObserver(Observer):
self._notify_dependent_property_changes(full_access_path) self._notify_dependent_property_changes(full_access_path)
def _update_cache_value( def _update_cache_value(
self, full_access_path: str, cached_value_dict: dict[str, Any], value: Any self, full_access_path: str, value: Any, cached_value_dict: dict[str, Any]
) -> None: ) -> None:
value_dict = dump(value)
if cached_value_dict != {}: if cached_value_dict != {}:
if cached_value_dict["type"] != value_dict["type"]:
logger.warning(
"Type of '%s' changed from '%s' to '%s'. This could have unwanted "
"side effects! Consider setting it to '%s' directly.",
full_access_path,
cached_value_dict["type"],
value_dict["type"],
cached_value_dict["type"],
)
self.state_manager._data_service_cache.update_cache( self.state_manager._data_service_cache.update_cache(
full_access_path, full_access_path,
value, value,