aboutsummaryrefslogtreecommitdiff
path: root/src/argaze/DataFeatures.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/argaze/DataFeatures.py')
-rw-r--r--src/argaze/DataFeatures.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/argaze/DataFeatures.py b/src/argaze/DataFeatures.py
index 1964093..0791d5e 100644
--- a/src/argaze/DataFeatures.py
+++ b/src/argaze/DataFeatures.py
@@ -245,11 +245,12 @@ def as_dict(obj: any, filter: bool = True) -> dict:
"""
_dict = {}
- for p in properties(obj.__class__):
+ for p in get_class_properties(obj.__class__):
v = getattr(obj, p)
if not filter or v is not None:
+
_dict[p] = v
return _dict
@@ -1199,6 +1200,7 @@ def PipelineStepMethod(method):
# Does the observer cares about this method?
if subscription_name in dir(observer):
+
subscription = getattr(observer, subscription_name)
# Call subscription
@@ -1206,6 +1208,7 @@ def PipelineStepMethod(method):
# Raise timestamped exception
if exception is not None:
+
raise TimestampedException(exception, timestamp)
return result