opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-08-28 20:26:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

[autofix.ci] apply automated fixes

Browse Source
This commit is contained in:
autofix-ci[bot] 2025-12-11 08:59:03 +00:00 committed by GitHub
parent 46d824b17f
commit 9616c6bb7d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
api/repositories/sqlalchemy_api_workflow_run_repository.py
View File

@ -365,9 +365,7 @@ class DifyAPISQLAlchemyWorkflowRunRepository(APIWorkflowRunRepository):
with self._session_maker() as session: with self._session_maker() as session:
node_execution_ids = session.scalars( node_execution_ids = session.scalars(
select(WorkflowNodeExecutionModel.id).where( select(WorkflowNodeExecutionModel.id).where(WorkflowNodeExecutionModel.workflow_run_id.in_(run_ids))
WorkflowNodeExecutionModel.workflow_run_id.in_(run_ids)
)
).all() ).all()
offloads_deleted = 0 offloads_deleted = 0
@ -400,9 +398,9 @@ class DifyAPISQLAlchemyWorkflowRunRepository(APIWorkflowRunRepository):
if pause_ids: if pause_ids:
pause_reasons_deleted = ( pause_reasons_deleted = (
session.query(WorkflowPauseReason).where(WorkflowPauseReason.pause_id.in_(pause_ids)).delete( session.query(WorkflowPauseReason)
synchronize_session=False .where(WorkflowPauseReason.pause_id.in_(pause_ids))
) .delete(synchronize_session=False)
) )
pauses_deleted = ( pauses_deleted = (
session.query(WorkflowPauseModel) session.query(WorkflowPauseModel)