Query
CREATE TABLE pipe_scheduler_state (
pipe_name TEXT PRIMARY KEY,
last_run_at TEXT,
last_success_at TEXT,
consecutive_failures INTEGER DEFAULT 0
)
CREATE TABLE pipe_scheduler_state (
pipe_name TEXT PRIMARY KEY,
last_run_at TEXT,
last_success_at TEXT,
consecutive_failures INTEGER DEFAULT 0
)