MIGRATIONS = ['CREATE TABLE IF NOT EXISTS checkpoint_migrations (
\n v INTEGER PRIMARY KEY\n);', "CREATE TABLE IF NOT EXISTS checkpoints (\n thread_id TEXT NOT NULL,
\n checkpoint_ns TEXT NOT NULL DEFAULT '',
\n type TEXT,
\n checkpoint JSONB NOT NULL,
\n metadata JSONB NOT NULL DEFAULT '{}',
\n PRIMARY KEY (thread_id, checkpoint_ns)\n);", "CREATE TABLE IF NOT EXISTS checkpoint_blobs (\n thread_id TEXT NOT NULL,
\n checkpoint_ns TEXT NOT NULL DEFAULT '',
\n channel TEXT NOT NULL,
\n type TEXT NOT NULL,
\n blob BYTEA,
\n PRIMARY KEY (thread_id, checkpoint_ns, channel)\n);", "CREATE TABLE IF NOT EXISTS checkpoint_writes (\n thread_id TEXT NOT NULL,
\n checkpoint_ns TEXT NOT NULL DEFAULT '',
\n checkpoint_id TEXT NOT NULL,
\n task_id TEXT NOT NULL,
\n idx INTEGER NOT NULL,
\n channel TEXT NOT NULL,
\n type TEXT,
\n blob BYTEA NOT NULL,
\n PRIMARY KEY (thread_id, checkpoint_ns, checkpoint_id, task_id, idx)\n);", '\n CREATE INDEX CONCURRENTLY IF NOT EXISTS checkpoints_thread_id_idx ON checkpoints(thread_id);\n ', '\n CREATE INDEX CONCURRENTLY IF NOT EXISTS checkpoint_blobs_thread_id_idx ON checkpoint_blobs(thread_id);\n ', '\n CREATE INDEX CONCURRENTLY IF NOT EXISTS checkpoint_writes_thread_id_idx ON checkpoint_writes(thread_id
);\n ', "\n ALTER TABLE checkpoint_writes ADD COLUMN IF NOT EXISTS task_path TEXT NOT NULL DEFAULT '';\n "]
