diff --git a/app/crud/crud_workflow_execution.py b/app/crud/crud_workflow_execution.py index 382c87cc7dc35a0e8dfdbc1fe9e21a2af01d7254..d05b5d5bd4efbd806b8047c9b6e04527188bd892 100644 --- a/app/crud/crud_workflow_execution.py +++ b/app/crud/crud_workflow_execution.py @@ -1,7 +1,7 @@ from uuid import UUID from clowmdb.models import WorkflowExecution -from sqlalchemy import delete, or_, select, update +from sqlalchemy import delete, or_, select, text, update from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.orm import joinedload @@ -146,7 +146,7 @@ class CRUDWorkflowExecution: stmt = ( update(WorkflowExecution) .where(WorkflowExecution._execution_id == eid) - .values(status=WorkflowExecution.WorkflowExecutionStatus.CANCELED.name) + .values(status=WorkflowExecution.WorkflowExecutionStatus.CANCELED.name, end_time=text("CURRENT_TIMESTAMP")) ) await db.execute(stmt) await db.commit()