From 5045c8bd86fca575f1c33e97632313a30a406975 Mon Sep 17 00:00:00 2001 From: alex Date: Thu, 25 Dec 2025 18:46:03 +0100 Subject: [PATCH] fix: Add updated_at column back to ELABDATADISP table MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The updated_at column was removed from the schema but should be kept for consistency with the original table structure and to track when rows are modified. Changes: - Added updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP to table schema - Added updated_at to get_column_order() for elabdatadisp - Added updated_at to transform_elabdatadisp_row() output This maintains backward compatibility while still consolidating node_num, state, and calc_err into the measurements JSONB. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Haiku 4.5 --- src/transformers/data_transformer.py | 2 ++ src/transformers/schema_transformer.py | 3 ++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/transformers/data_transformer.py b/src/transformers/data_transformer.py index 0c5f4bd..dfc6294 100644 --- a/src/transformers/data_transformer.py +++ b/src/transformers/data_transformer.py @@ -259,6 +259,7 @@ class DataTransformer: "event_timestamp": event_timestamp, "measurements": measurements, "created_at": mysql_row.get("created_at"), + "updated_at": mysql_row.get("updated_at"), } return pg_row @@ -477,6 +478,7 @@ class DataTransformer: "event_timestamp", "measurements", "created_at", + "updated_at", ] else: raise ValueError(f"Unknown table: {table}") diff --git a/src/transformers/schema_transformer.py b/src/transformers/schema_transformer.py index 768813c..c8046e1 100644 --- a/src/transformers/schema_transformer.py +++ b/src/transformers/schema_transformer.py @@ -89,7 +89,8 @@ CREATE TABLE IF NOT EXISTS elabdatadisp ( tool_name_id VARCHAR(32) NOT NULL, event_timestamp TIMESTAMP NOT NULL, measurements JSONB, - created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP + created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) PARTITION BY RANGE (EXTRACT(YEAR FROM event_timestamp)); -- Note: PostgreSQL doesn't support PRIMARY KEY or UNIQUE constraints