From 9f18d3ce07c457d3b05a557c7d6d408a2a9f7538 Mon Sep 17 00:00:00 2001 From: liqiang-fit2cloud Date: Fri, 28 Nov 2025 09:35:52 +0800 Subject: [PATCH] refactor: change heartbeat file dir. --- apps/ops/celery/heartbeat.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/ops/celery/heartbeat.py b/apps/ops/celery/heartbeat.py index 339a3c60a..e87038f88 100644 --- a/apps/ops/celery/heartbeat.py +++ b/apps/ops/celery/heartbeat.py @@ -6,14 +6,14 @@ from celery.signals import heartbeat_sent, worker_ready, worker_shutdown @heartbeat_sent.connect def heartbeat(sender, **kwargs): worker_name = sender.eventer.hostname.split('@')[0] - heartbeat_path = Path('/tmp/worker_heartbeat_{}'.format(worker_name)) + heartbeat_path = Path('/opt/maxkb-app/tmp/worker_heartbeat_{}'.format(worker_name)) heartbeat_path.touch() @worker_ready.connect def worker_ready(sender, **kwargs): worker_name = sender.hostname.split('@')[0] - ready_path = Path('/tmp/worker_ready_{}'.format(worker_name)) + ready_path = Path('/opt/maxkb-app/tmp/worker_ready_{}'.format(worker_name)) ready_path.touch() @@ -21,5 +21,5 @@ def worker_ready(sender, **kwargs): def worker_shutdown(sender, **kwargs): worker_name = sender.hostname.split('@')[0] for signal in ['ready', 'heartbeat']: - path = Path('/tmp/worker_{}_{}'.format(signal, worker_name)) + path = Path('/opt/maxkb-app/tmp/worker_{}_{}'.format(signal, worker_name)) path.unlink(missing_ok=True)