chore(db): update db schema to include "fetching" status
This commit is contained in:
@@ -114,7 +114,7 @@ class DatasetManager:
|
|||||||
self.db.execute_batch(query, values)
|
self.db.execute_batch(query, values)
|
||||||
|
|
||||||
def set_dataset_status(self, dataset_id: int, status: str, status_message: str | None = None):
|
def set_dataset_status(self, dataset_id: int, status: str, status_message: str | None = None):
|
||||||
if status not in ["processing", "complete", "error"]:
|
if status not in ["fetching", "processing", "complete", "error"]:
|
||||||
raise ValueError("Invalid status")
|
raise ValueError("Invalid status")
|
||||||
|
|
||||||
query = """
|
query = """
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ CREATE TABLE datasets (
|
|||||||
|
|
||||||
-- Enforce valid states
|
-- Enforce valid states
|
||||||
CONSTRAINT datasets_status_check
|
CONSTRAINT datasets_status_check
|
||||||
CHECK (status IN ('processing', 'complete', 'error'))
|
CHECK (status IN ('fetching', 'processing', 'complete', 'error'))
|
||||||
);
|
);
|
||||||
|
|
||||||
CREATE TABLE events (
|
CREATE TABLE events (
|
||||||
|
|||||||
Reference in New Issue
Block a user