summaryrefslogblamecommitdiff
path: root/makima/migrations/20250114000002_daemon_capabilities.sql
blob: 0c2e1c2f7d1fedecb9df3afee88b66fe25b0052a (plain) (tree)


























                                                                                                                    
-- Daemon capabilities for multi-daemon work distribution
-- Adds selection scoring and task assignment tracking

-- Extend daemons table for multi-daemon selection
ALTER TABLE daemons ADD COLUMN IF NOT EXISTS capacity_score INTEGER DEFAULT 100;
ALTER TABLE daemons ADD COLUMN IF NOT EXISTS task_queue_length INTEGER DEFAULT 0;
ALTER TABLE daemons ADD COLUMN IF NOT EXISTS supports_migration BOOLEAN DEFAULT true;

-- Track active task assignments per daemon
-- This allows moving tasks between daemons
CREATE TABLE IF NOT EXISTS daemon_task_assignments (
    id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
    daemon_id UUID NOT NULL REFERENCES daemons(id) ON DELETE CASCADE,
    task_id UUID NOT NULL REFERENCES tasks(id) ON DELETE CASCADE,
    assigned_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
    status VARCHAR(32) NOT NULL DEFAULT 'active',  -- active, migrating, completed

    UNIQUE(task_id)  -- A task can only be assigned to one daemon at a time
);

CREATE INDEX idx_daemon_task_assignments_daemon_id ON daemon_task_assignments(daemon_id);
CREATE INDEX idx_daemon_task_assignments_status ON daemon_task_assignments(status);

COMMENT ON COLUMN daemons.capacity_score IS 'Relative capacity score for daemon selection (higher = more capacity)';
COMMENT ON COLUMN daemons.task_queue_length IS 'Number of tasks queued/waiting on this daemon';
COMMENT ON COLUMN daemons.supports_migration IS 'Whether this daemon supports task migration';
COMMENT ON TABLE daemon_task_assignments IS 'Tracks task-to-daemon assignments for migration support';