Compare commits

..

No commits in common. "aaf88a6f1283992d7524d7e505e50efc16f5ef46" and "b789c1bd445dbaa234f2ab6f1d192593e8e62cd6" have entirely different histories.

View File

@ -69,12 +69,6 @@ BOOLEAN_COLUMNS = {
'ai_prompts': ['active'], 'ai_prompts': ['active'],
} }
# Column whitelist for tables that have schema differences
# Only these columns will be migrated (filters out legacy columns)
COLUMN_WHITELIST = {
'ai_insights': ['id', 'profile_id', 'scope', 'content', 'created'],
}
# ================================================================ # ================================================================
# CONVERSION HELPERS # CONVERSION HELPERS
@ -179,17 +173,8 @@ def migrate_table(pg_conn, table: str) -> Dict[str, int]:
# Convert rows # Convert rows
converted_rows = [convert_row(row, table) for row in sqlite_rows] converted_rows = [convert_row(row, table) for row in sqlite_rows]
# Get column names - filter if whitelist exists for this table # Get column names
if table in COLUMN_WHITELIST: columns = list(converted_rows[0].keys())
allowed_columns = COLUMN_WHITELIST[table]
# Filter rows to only include allowed columns
converted_rows = [
{k: v for k, v in row.items() if k in allowed_columns}
for row in converted_rows
]
columns = allowed_columns
else:
columns = list(converted_rows[0].keys())
cols_str = ', '.join(columns) cols_str = ', '.join(columns)
placeholders = ', '.join(['%s'] * len(columns)) placeholders = ', '.join(['%s'] * len(columns))