diff --git a/apps/common/job/clean_chat_job.py b/apps/common/job/clean_chat_job.py index 50b467c8b..bf7dd362d 100644 --- a/apps/common/job/clean_chat_job.py +++ b/apps/common/job/clean_chat_job.py @@ -22,7 +22,7 @@ def clean_chat_log_job(): clean_chat_log_job_lock() -@lock(lock_key='clean_chat_log_job', timeout=30) +@lock(lock_key='clean_chat_log_job_execute', timeout=30) def clean_chat_log_job_lock(): from django.utils.translation import gettext_lazy as _ maxkb_logger.info(_('start clean chat log')) diff --git a/apps/common/job/clean_debug_file_job.py b/apps/common/job/clean_debug_file_job.py index 41493decc..3fa6f4a36 100644 --- a/apps/common/job/clean_debug_file_job.py +++ b/apps/common/job/clean_debug_file_job.py @@ -19,7 +19,7 @@ def clean_debug_file(): clean_debug_file_lock() -@lock(lock_key='clean_debug_file', timeout=30) +@lock(lock_key='clean_debug_file_execute', timeout=30) def clean_debug_file_lock(): from django.utils.translation import gettext_lazy as _ maxkb_logger.info(_('start clean debug file')) @@ -35,7 +35,7 @@ def clean_debug_file_lock(): def run(): - if try_lock('clean_debug_file', 30): + if try_lock('clean_debug_file', 30 * 30): try: scheduler.start() clean_debug_file_job = scheduler.get_job(job_id='clean_debug_file') diff --git a/apps/common/job/client_access_num_job.py b/apps/common/job/client_access_num_job.py index cd86b7827..2b35935cf 100644 --- a/apps/common/job/client_access_num_job.py +++ b/apps/common/job/client_access_num_job.py @@ -24,7 +24,7 @@ def client_access_num_reset_job(): client_access_num_reset_job_lock() -@lock(lock_key="access_num_reset", timeout=30) +@lock(lock_key="access_num_reset_execute", timeout=30) def client_access_num_reset_job_lock(): from django.utils.translation import gettext_lazy as _ maxkb_logger.info(_('start reset access_num')) @@ -33,7 +33,7 @@ def client_access_num_reset_job_lock(): def run(): - if try_lock('access_num_reset', 30): + if try_lock('access_num_reset', 30 * 30): try: scheduler.start() access_num_reset = scheduler.get_job(job_id='access_num_reset')