toki
bbb1179194
Tasks 테이블에 external_provider, external_id 기반 UPSERT 로직을 추가하고 GetTaskByExternalRef 쿼리를 신설하여 중복 작업을 효율적으로 처리한다. 외부 참조 고유 인덱스 마이그레이션(00008)을 추가한다. Workspace slots 쿼리에서 alias를 명시하여 FOR UPDATE SKIP LOCKED 동시성 처리를 개선한다. Storage, workflow, workitempipeline의 중복 처리 로직을 일관되게 적용하고 Plane 웹훅 테스트를 보강한다.
46 lines
2.2 KiB
SQL
46 lines
2.2 KiB
SQL
-- name: CreateTask :one
|
|
INSERT INTO tasks (title, source, payload, metadata, external_provider, external_id, external_url, external_metadata)
|
|
VALUES ($1, $2, $3, $4, $5, $6, $7, $8)
|
|
ON CONFLICT (external_provider, external_id) WHERE external_provider IS NOT NULL AND external_id IS NOT NULL
|
|
DO UPDATE SET updated_at = tasks.updated_at
|
|
RETURNING id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata;
|
|
|
|
-- name: GetTaskByExternalRef :one
|
|
SELECT id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata
|
|
FROM tasks
|
|
WHERE external_provider = $1 AND external_id = $2;
|
|
|
|
-- name: GetTask :one
|
|
SELECT id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata
|
|
FROM tasks
|
|
WHERE id::text = $1;
|
|
|
|
-- name: ListTasks :many
|
|
SELECT id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata
|
|
FROM tasks
|
|
ORDER BY created_at DESC
|
|
LIMIT $1;
|
|
|
|
-- name: UpdateTaskStatus :one
|
|
UPDATE tasks
|
|
SET status = $2, updated_at = now()
|
|
WHERE id::text = $1
|
|
RETURNING id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata;
|
|
|
|
-- name: UpdateTaskMetadata :one
|
|
UPDATE tasks
|
|
SET metadata = $2, updated_at = now()
|
|
WHERE id::text = $1
|
|
RETURNING id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata;
|
|
|
|
-- name: CompleteTask :one
|
|
UPDATE tasks
|
|
SET status = 'completed', result = $2, error = NULL, updated_at = now()
|
|
WHERE id::text = $1
|
|
RETURNING id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata;
|
|
|
|
-- name: FailTask :one
|
|
UPDATE tasks
|
|
SET status = 'failed', error = $2, updated_at = now()
|
|
WHERE id::text = $1
|
|
RETURNING id, title, source, status, payload, result, error, created_at, updated_at, external_provider, external_id, external_url, external_metadata, metadata;
|