From 7a47b8621bb0d4bf3e3aee73123bdb716d03b846 Mon Sep 17 00:00:00 2001 From: -LAN- Date: Mon, 14 Jul 2025 14:14:52 +0800 Subject: [PATCH] refactor(remove_app_and_related_data_task): Remove 'expire_on_commit' to prevent session issues Signed-off-by: -LAN- --- api/tasks/remove_app_and_related_data_task.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/api/tasks/remove_app_and_related_data_task.py b/api/tasks/remove_app_and_related_data_task.py index 9545afbde6..179adcbd6e 100644 --- a/api/tasks/remove_app_and_related_data_task.py +++ b/api/tasks/remove_app_and_related_data_task.py @@ -192,7 +192,7 @@ def _delete_app_workflows(tenant_id: str, app_id: str): def _delete_app_workflow_runs(tenant_id: str, app_id: str): """Delete all workflow runs for an app using the service repository.""" - session_maker = sessionmaker(bind=db.engine, expire_on_commit=False) + session_maker = sessionmaker(bind=db.engine) workflow_run_repo = DifyAPIRepositoryFactory.create_api_workflow_run_repository(session_maker) deleted_count = workflow_run_repo.delete_runs_by_app( @@ -206,7 +206,7 @@ def _delete_app_workflow_runs(tenant_id: str, app_id: str): def _delete_app_workflow_node_executions(tenant_id: str, app_id: str): """Delete all workflow node executions for an app using the service repository.""" - session_maker = sessionmaker(bind=db.engine, expire_on_commit=False) + session_maker = sessionmaker(bind=db.engine) node_execution_repo = DifyAPIRepositoryFactory.create_api_workflow_node_execution_repository(session_maker) deleted_count = node_execution_repo.delete_executions_by_app(