diff --git a/audit/__init__.py b/audit/__init__.py
index 5c6a5d07..5a88743f 100644
--- a/audit/__init__.py
+++ b/audit/__init__.py
@@ -1095,6 +1095,9 @@ async def drain_audit_redis_to_db(session_factory: Any) -> int:
                                 created = datetime.now(timezone.utc)
                         elif created is None:
                             created = datetime.now(timezone.utc)
+                        elif not isinstance(created, datetime):
+                            created = datetime.now(timezone.utc)
+                        created = _naive_utc(created)
                         event = AuditEvent(
                             event_type=rec.get("event_type", "telegram_access"),
                             channel=rec.get("channel", "telegram"),