update: delete schedule
This commit is contained in:
@@ -556,6 +556,7 @@ async def create_schedule(
|
|||||||
select(Schedules).where(
|
select(Schedules).where(
|
||||||
Schedules.workspace_id == context.workspace.workspace_id,
|
Schedules.workspace_id == context.workspace.workspace_id,
|
||||||
Schedules.schedule_name == payload.schedule_name,
|
Schedules.schedule_name == payload.schedule_name,
|
||||||
|
Schedules.is_deleted == 0,
|
||||||
Schedules.deleted_at.is_(None),
|
Schedules.deleted_at.is_(None),
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
@@ -645,6 +646,7 @@ async def update_schedule(
|
|||||||
Schedules.workspace_id == context.workspace.workspace_id,
|
Schedules.workspace_id == context.workspace.workspace_id,
|
||||||
Schedules.schedule_name == payload.schedule_name,
|
Schedules.schedule_name == payload.schedule_name,
|
||||||
Schedules.schedule_id != schedule_id,
|
Schedules.schedule_id != schedule_id,
|
||||||
|
Schedules.is_deleted == 0,
|
||||||
Schedules.deleted_at.is_(None),
|
Schedules.deleted_at.is_(None),
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
@@ -753,6 +755,7 @@ async def delete_schedule(
|
|||||||
item.next_run_at = None
|
item.next_run_at = None
|
||||||
item.deleted_at = _mysql_utc(datetime.now(UTC))
|
item.deleted_at = _mysql_utc(datetime.now(UTC))
|
||||||
item.updated_by = context.user.user_id
|
item.updated_by = context.user.user_id
|
||||||
|
item.is_deleted = 1
|
||||||
item.workflow_version += 1
|
item.workflow_version += 1
|
||||||
await session.flush()
|
await session.flush()
|
||||||
return {
|
return {
|
||||||
|
|||||||
Reference in New Issue
Block a user