admin/ai-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add AI job queue indexes

Browse Source
This commit is contained in:
Grendgi
2026-06-09 11:41:15 +03:00
parent 01ee090fa5
commit 092994fe74
3 changed files with 30 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
internal/migrate/sql/004_ai_jobs_queue_indexes.up.sql Normal file
View File

@@ -0,0 +1,13 @@
CREATE INDEX IF NOT EXISTS ai_jobs_pending_claim_scope_idx
ON ai_jobs (task_type, model_profile, priority DESC, scheduled_at DESC, created_at DESC)
WHERE status = 'pending';
CREATE INDEX IF NOT EXISTS ai_jobs_running_lease_idx
ON ai_jobs ((COALESCE(heartbeat_at, started_at, updated_at)))
WHERE status = 'running';
CREATE INDEX IF NOT EXISTS ai_jobs_queue_stats_idx
ON ai_jobs (task_type, model_profile, status);
CREATE INDEX IF NOT EXISTS ai_jobs_owner_stats_idx
ON ai_jobs (owner_service, task_type, model_profile, status);

4
migrations/004_ai_jobs_queue_indexes.down.sql Normal file
View File

@@ -0,0 +1,4 @@
DROP INDEX IF EXISTS ai_jobs_owner_stats_idx;
DROP INDEX IF EXISTS ai_jobs_queue_stats_idx;
DROP INDEX IF EXISTS ai_jobs_running_lease_idx;
DROP INDEX IF EXISTS ai_jobs_pending_claim_scope_idx;

13
migrations/004_ai_jobs_queue_indexes.up.sql Normal file
View File

@@ -0,0 +1,13 @@
CREATE INDEX IF NOT EXISTS ai_jobs_pending_claim_scope_idx
ON ai_jobs (task_type, model_profile, priority DESC, scheduled_at DESC, created_at DESC)
WHERE status = 'pending';
CREATE INDEX IF NOT EXISTS ai_jobs_running_lease_idx
ON ai_jobs ((COALESCE(heartbeat_at, started_at, updated_at)))
WHERE status = 'running';
CREATE INDEX IF NOT EXISTS ai_jobs_queue_stats_idx
ON ai_jobs (task_type, model_profile, status);
CREATE INDEX IF NOT EXISTS ai_jobs_owner_stats_idx
ON ai_jobs (owner_service, task_type, model_profile, status);