estel/dify
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix: Update the scheduling method for timed tasks, (#22779)

Browse Source
This commit is contained in:
GuanMu
2025-07-25 16:27:35 +08:00
committed by GitHub
parent ad472d59e0
commit 9c5b1e7012
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
api/extensions/ext_celery.py
View File

@@ -73,13 +73,13 @@ def init_app(app: DifyApp) -> Celery:
imports.append("schedule.clean_embedding_cache_task") imports.append("schedule.clean_embedding_cache_task")
beat_schedule["clean_embedding_cache_task"] = { beat_schedule["clean_embedding_cache_task"] = {
"task": "schedule.clean_embedding_cache_task.clean_embedding_cache_task", "task": "schedule.clean_embedding_cache_task.clean_embedding_cache_task",
"schedule": timedelta(days=day), "schedule": crontab(minute="0", hour="2", day_of_month=f"*/{day}"),
} }
if dify_config.ENABLE_CLEAN_UNUSED_DATASETS_TASK: if dify_config.ENABLE_CLEAN_UNUSED_DATASETS_TASK:
imports.append("schedule.clean_unused_datasets_task") imports.append("schedule.clean_unused_datasets_task")
beat_schedule["clean_unused_datasets_task"] = { beat_schedule["clean_unused_datasets_task"] = {
"task": "schedule.clean_unused_datasets_task.clean_unused_datasets_task", "task": "schedule.clean_unused_datasets_task.clean_unused_datasets_task",
"schedule": timedelta(days=day), "schedule": crontab(minute="0", hour="3", day_of_month=f"*/{day}"),
} }
if dify_config.ENABLE_CREATE_TIDB_SERVERLESS_TASK: if dify_config.ENABLE_CREATE_TIDB_SERVERLESS_TASK:
imports.append("schedule.create_tidb_serverless_task") imports.append("schedule.create_tidb_serverless_task")
@@ -97,7 +97,7 @@ def init_app(app: DifyApp) -> Celery:
imports.append("schedule.clean_messages") imports.append("schedule.clean_messages")
beat_schedule["clean_messages"] = { beat_schedule["clean_messages"] = {
"task": "schedule.clean_messages.clean_messages", "task": "schedule.clean_messages.clean_messages",
"schedule": timedelta(days=day), "schedule": crontab(minute="0", hour="4", day_of_month=f"*/{day}"),
} }
if dify_config.ENABLE_MAIL_CLEAN_DOCUMENT_NOTIFY_TASK: if dify_config.ENABLE_MAIL_CLEAN_DOCUMENT_NOTIFY_TASK:
imports.append("schedule.mail_clean_document_notify_task") imports.append("schedule.mail_clean_document_notify_task")