diff --git a/backend/src/backend/api/schedules/schedules.py b/backend/src/backend/api/schedules/schedules.py index dcd91c1..5c724fe 100644 --- a/backend/src/backend/api/schedules/schedules.py +++ b/backend/src/backend/api/schedules/schedules.py @@ -556,6 +556,7 @@ async def create_schedule( select(Schedules).where( Schedules.workspace_id == context.workspace.workspace_id, Schedules.schedule_name == payload.schedule_name, + Schedules.is_deleted == 0, Schedules.deleted_at.is_(None), ) ) @@ -645,6 +646,7 @@ async def update_schedule( Schedules.workspace_id == context.workspace.workspace_id, Schedules.schedule_name == payload.schedule_name, Schedules.schedule_id != schedule_id, + Schedules.is_deleted == 0, Schedules.deleted_at.is_(None), ) ) @@ -753,6 +755,7 @@ async def delete_schedule( item.next_run_at = None item.deleted_at = _mysql_utc(datetime.now(UTC)) item.updated_by = context.user.user_id + item.is_deleted = 1 item.workflow_version += 1 await session.flush() return {