diff --git a/frappe/pulse/client.py b/frappe/pulse/client.py index cceee11b5e..7ffe3a6e28 100644 --- a/frappe/pulse/client.py +++ b/frappe/pulse/client.py @@ -75,6 +75,7 @@ def _queue_event(event): def queue_length(): return frappe.cache.llen("pulse-client:events") + def send_queued_events(): batch_size = 100 max_batches = 10