Cleanup

Author: febus982

domains/cloudevent_base.py

@@ -229,6 +229,3 @@ class BaseEvent(pydantic.BaseModel, abc.ABC):
         "datacontenttype",
         "dataschema",
     )
-
-    def get_attributes(self) -> typing.Dict[str, typing.Any]:
-        return {key: getattr(self, key, None) for key in self._ce_valid_attrs}

gateways/event.py

@@ -10,6 +10,5 @@ async def emit(
         logger = get_logger()
         await logger.ainfo(
             "Event emitted",
-            attributes=event.get_attributes(),
-            data=event.data.model_dump() if event.data else None,
+            cloudevent=event.model_dump(),
         )