20f4086a77
* feat: add worker_group_job_stats table for job metrics aggregation - Add new table with hour timestamp, worker group, script lang, workspace_id, job count and total duration - Workers accumulate stats in memory and update hourly via sum aggregation - Monitor.rs cleans up rows older than 60 days periodically - Stats are flushed on worker shutdown to prevent data loss Co-authored-by: windmill-internal-app[bot] <windmill-internal-app[bot]@users.noreply.github.com> * all * all * ee-repo-ref * nits * nits --------- Co-authored-by: claude[bot] <209825114+claude[bot]@users.noreply.github.com> Co-authored-by: windmill-internal-app[bot] <windmill-internal-app[bot]@users.noreply.github.com> Co-authored-by: Ruben Fiszel <ruben@windmill.dev>
15 lines
788 B
SQL
15 lines
788 B
SQL
-- Add worker_group_job_stats table
|
|
CREATE TABLE IF NOT EXISTS worker_group_job_stats (
|
|
hour BIGINT NOT NULL,
|
|
worker_group TEXT NOT NULL,
|
|
script_lang VARCHAR(50),
|
|
workspace_id VARCHAR(50) NOT NULL REFERENCES workspace(id) ON DELETE CASCADE,
|
|
job_count INTEGER NOT NULL DEFAULT 0,
|
|
total_duration_ms BIGINT NOT NULL DEFAULT 0,
|
|
PRIMARY KEY (hour, worker_group, script_lang, workspace_id)
|
|
);
|
|
|
|
-- Create indices for efficient querying
|
|
CREATE INDEX IF NOT EXISTS worker_group_job_stats_hour_idx ON worker_group_job_stats(hour DESC);
|
|
CREATE INDEX IF NOT EXISTS worker_group_job_stats_workspace_idx ON worker_group_job_stats(workspace_id, hour DESC);
|
|
CREATE INDEX IF NOT EXISTS worker_group_job_stats_worker_group_idx ON worker_group_job_stats(worker_group, hour DESC); |