"""Serialization utilities for ows-account.""" import datetime def serialize_event_value(obj): """Serialize a value for use in a Kafka event payload. Converts date and datetime objects to ISO 8601 strings; passes other types through unchanged. """ if isinstance(obj, datetime.date): return obj.isoformat() return obj def serialize_event(event: dict) -> dict: """Return a copy of event with all values serialized for Kafka.""" return {k: serialize_event_value(v) for k, v in event.items()}