diff options
-rw-r--r-- | src/argaze/DataFeatures.py | 5 |
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 |