diff --git a/dbt_common/events/functions.py b/dbt_common/events/functions.py index 6402c791..fe29a543 100644 --- a/dbt_common/events/functions.py +++ b/dbt_common/events/functions.py @@ -94,7 +94,7 @@ def msg_to_dict(msg: EventMsg) -> dict: msg_dict = dict() try: msg_dict = MessageToDict( - msg, + msg.data, preserving_proto_field_name=True, including_default_value_fields=True, # type: ignore )