toki
bbb1179194
Tasks 테이블에 external_provider, external_id 기반 UPSERT 로직을 추가하고 GetTaskByExternalRef 쿼리를 신설하여 중복 작업을 효율적으로 처리한다. 외부 참조 고유 인덱스 마이그레이션(00008)을 추가한다. Workspace slots 쿼리에서 alias를 명시하여 FOR UPDATE SKIP LOCKED 동시성 처리를 개선한다. Storage, workflow, workitempipeline의 중복 처리 로직을 일관되게 적용하고 Plane 웹훅 테스트를 보강한다.
30 lines
1.1 KiB
SQL
30 lines
1.1 KiB
SQL
-- name: ListWorkspaceSlotsByProject :many
|
|
SELECT id, project_sync_setting_id, slot_index, state, path, created_at, updated_at
|
|
FROM workspace_slots
|
|
WHERE project_sync_setting_id = $1
|
|
ORDER BY slot_index;
|
|
|
|
-- name: UpsertWorkspaceSlot :one
|
|
INSERT INTO workspace_slots (project_sync_setting_id, slot_index, state, path)
|
|
VALUES ($1, $2, 'available', $3)
|
|
ON CONFLICT (project_sync_setting_id, slot_index)
|
|
DO UPDATE SET path = EXCLUDED.path, updated_at = now()
|
|
RETURNING id, project_sync_setting_id, slot_index, state, path, created_at, updated_at;
|
|
|
|
-- name: ReserveAvailableWorkspaceSlot :one
|
|
UPDATE workspace_slots
|
|
SET state = 'in_use', updated_at = now()
|
|
WHERE id = (
|
|
SELECT ws.id FROM workspace_slots ws
|
|
WHERE ws.project_sync_setting_id = $1 AND ws.state = 'available'
|
|
ORDER BY ws.slot_index
|
|
LIMIT 1
|
|
FOR UPDATE SKIP LOCKED
|
|
)
|
|
RETURNING id, project_sync_setting_id, slot_index, state, path, created_at, updated_at;
|
|
|
|
-- name: UpdateWorkspaceSlotState :one
|
|
UPDATE workspace_slots
|
|
SET state = $2, updated_at = now()
|
|
WHERE id = $1
|
|
RETURNING id, project_sync_setting_id, slot_index, state, path, created_at, updated_at;
|