diff --git a/frappe/api/__init__.py b/frappe/api/__init__.py index 32a4257c11..7d7a665ce7 100644 --- a/frappe/api/__init__.py +++ b/frappe/api/__init__.py @@ -8,9 +8,8 @@ from werkzeug.routing import Map, Submount from werkzeug.wrappers import Request, Response import frappe -import frappe.client from frappe import _ -from frappe.pulse.app_activity_event import log_app_activity +from frappe.pulse.app_heartbeat_event import log_app_heartbeat from frappe.utils.response import build_response @@ -68,7 +67,7 @@ def handle(request: Request): data = build_response("json") with suppress(Exception): - log_app_activity(arguments) + log_app_heartbeat(arguments) return data diff --git a/frappe/hooks.py b/frappe/hooks.py index 347b855591..0ed8bc2042 100644 --- a/frappe/hooks.py +++ b/frappe/hooks.py @@ -216,7 +216,7 @@ scheduler_events = { ], # 6 hours "0 */6 * * *": [ - "frappe.pulse.app_activity_event.send", + "frappe.pulse.app_heartbeat_event.send", ], # Hourly but offset by 30 minutes "30 * * * *": [], diff --git a/frappe/pulse/app_activity_event.py b/frappe/pulse/app_heartbeat_event.py similarity index 93% rename from frappe/pulse/app_activity_event.py rename to frappe/pulse/app_heartbeat_event.py index 82a88fa97e..4a5e496d8e 100644 --- a/frappe/pulse/app_activity_event.py +++ b/frappe/pulse/app_heartbeat_event.py @@ -8,7 +8,7 @@ KEY = "pulse:active_apps" EXPIRY = 60 * 60 * 12 # 12 hours -def log_app_activity(req_params): +def log_app_heartbeat(req_params): if not is_enabled() or frappe.session.user in ("Guest", "Administrator"): return @@ -46,7 +46,7 @@ def send(): for app in active_apps: events.append( { - "name": "app_activity", + "name": "app_heartbeat", "app": app, "app_version": _get_app_version(app), } @@ -56,7 +56,7 @@ def send(): if post_events(events): frappe.cache.delete_value(KEY) except Exception: - frappe.log_error(title="Failed to send app activity events") + frappe.log_error(title="Failed to send app heartbeat events") def _mark_active(app):