fix: unhandled attribute exception

bamcs · Sep 28, 2023 · ca3b513 · ca3b513
1 parent 096ac50
commit ca3b513
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/microsoft_azure_eventhub_source/_CleanEvent.py b/microsoft_azure_eventhub_source/_CleanEvent.py
@@ -23,6 +23,8 @@ def CleanEvent(source_dict: dict):
                 value = orjson.loads(value)
                 CleanEvent(value)
                 source_dict[key] = value
+            except AttributeError:
+                pass
             except orjson.JSONDecodeError:
                 pass
         elif isinstance(value, dict) and not value: