From cf1cae51f780e987486345c8c7db906a39a20af6 Mon Sep 17 00:00:00 2001 From: goulustis Date: Wed, 4 Mar 2026 15:36:08 +0800 Subject: [PATCH] add pipeline id to sql conv store --- scripts/init_database/create_conv_store.sql | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/scripts/init_database/create_conv_store.sql b/scripts/init_database/create_conv_store.sql index a138d16..d8d39d0 100644 --- a/scripts/init_database/create_conv_store.sql +++ b/scripts/init_database/create_conv_store.sql @@ -2,6 +2,7 @@ CREATE TABLE IF NOT EXISTS messages ( id BIGSERIAL PRIMARY KEY, conversation_id TEXT NOT NULL, + pipeline_id TEXT, message_type VARCHAR(10) NOT NULL CHECK (message_type IN ('human', 'ai', 'tool')), content TEXT NOT NULL, sequence_number INTEGER NOT NULL CHECK (sequence_number >= 0), @@ -9,4 +10,7 @@ CREATE TABLE IF NOT EXISTS messages ( ); -- Index for fast retrieval of all messages in a conversation (in order) -CREATE INDEX IF NOT EXISTS idx_messages_conversation ON messages (conversation_id, sequence_number); \ No newline at end of file +CREATE INDEX IF NOT EXISTS idx_messages_conversation ON messages (conversation_id, sequence_number); + +-- Index for fast lookup by pipeline_id +CREATE INDEX IF NOT EXISTS idx_messages_pipeline ON messages (pipeline_id); \ No newline at end of file