yujunjun/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2025-10-31 02:42:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: optimize query for expired workflow runs by adding date filter and limiting results (#16491)

Browse Source
This commit is contained in:
Yeuoly 2025-03-22 11:17:21 +08:00 committed by GitHub
parent 4448a54cc1
commit 1907d2a90a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
api/services/clear_free_plan_tenant_expired_logs.py
View File

@ -149,7 +149,15 @@ class ClearFreePlanTenantExpiredLogs:
while True:
with Session(db.engine).no_autoflush as session:
workflow_runs = session.query(WorkflowRun).filter(WorkflowRun.tenant_id == tenant_id).all()
workflow_runs = (
session.query(WorkflowRun)
.filter(
WorkflowRun.tenant_id == tenant_id,
WorkflowRun.created_at < datetime.datetime.now() - datetime.timedelta(days=days),
)
.limit(batch)
.all()
)
if len(workflow_runs) == 0:
break