def normalise_event()

in share/events.py [0:0]

• 9 lines of code
• 4 McCabe index (conditional complexity)

def normalise_event(event_payload: dict[str, Any]) -> dict[str, Any]:
    """
    This method move fields payload in the event at root level and then removes it with meta payload
    It has to be called as last step after any operation on the event payload just before sending to the cluster
    """
    if "fields" in event_payload:
        fields: dict[str, Any] = event_payload["fields"]
        for field_key in fields.keys():
            event_payload[field_key] = fields[field_key]

        del event_payload["fields"]

    if "meta" in event_payload:
        del event_payload["meta"]

    return event_payload