From 3835ae936461f44b29b692850b69760d125442ea Mon Sep 17 00:00:00 2001 From: Yeuoly Date: Fri, 21 Mar 2025 21:49:58 +0800 Subject: [PATCH] fix: add batch size to ClearFreePlainTenantExpiredLogs to avoid blocking --- api/services/clear_free_plan_tenant_expired_logs.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/api/services/clear_free_plan_tenant_expired_logs.py b/api/services/clear_free_plan_tenant_expired_logs.py index 25cad92e14..b1200517ba 100644 --- a/api/services/clear_free_plan_tenant_expired_logs.py +++ b/api/services/clear_free_plan_tenant_expired_logs.py @@ -149,7 +149,9 @@ 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).limit(batch).all() + ) if len(workflow_runs) == 0: break