record_payload.py 291 B

123456789
  1. from __future__ import annotations
  2. from copy import deepcopy
  3. from typing import Any
  4. def with_raw_payload(record: dict[str, Any]) -> dict[str, Any]:
  5. payload = {key: deepcopy(value) for key, value in record.items() if key != "raw_payload"}
  6. return {**record, "raw_payload": payload}