diff --git a/frappe/realtime.py b/frappe/realtime.py index c2294bfca1..216621b53b 100644 --- a/frappe/realtime.py +++ b/frappe/realtime.py @@ -84,6 +84,8 @@ def publish_realtime( def flush_realtime_log(): + if not hasattr(frappe.local, "_realtime_log"): + return for args in frappe.local._realtime_log: frappe.realtime.emit_via_redis(*args)