refactor: rename app_activity to app_heartbeat
This commit is contained in:
parent
4ec052a971
commit
7f0765fc9e
3 changed files with 6 additions and 7 deletions
|
|
@ -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
|
||||
|
||||
|
|
|
|||
|
|
@ -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 * * * *": [],
|
||||
|
|
|
|||
|
|
@ -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):
|
||||
Loading…
Add table
Reference in a new issue