Commit ·
2109c4e
1
Parent(s): 430c361
[NOTICKET] add column updated_at on catalog
Browse files- src/catalog/store.py +2 -1
src/catalog/store.py
CHANGED
|
@@ -4,7 +4,7 @@ Storage shape: one row per user in a `catalogs` table with columns
|
|
| 4 |
(user_id PK, data jsonb, schema_version, generated_at, updated_at).
|
| 5 |
"""
|
| 6 |
|
| 7 |
-
from sqlalchemy import delete, select
|
| 8 |
from sqlalchemy.dialects.postgresql import insert
|
| 9 |
|
| 10 |
from src.db.postgres.connection import AsyncSessionLocal
|
|
@@ -49,6 +49,7 @@ class CatalogStore:
|
|
| 49 |
"data": stmt.excluded.data,
|
| 50 |
"schema_version": stmt.excluded.schema_version,
|
| 51 |
"generated_at": stmt.excluded.generated_at,
|
|
|
|
| 52 |
},
|
| 53 |
)
|
| 54 |
await session.execute(stmt)
|
|
|
|
| 4 |
(user_id PK, data jsonb, schema_version, generated_at, updated_at).
|
| 5 |
"""
|
| 6 |
|
| 7 |
+
from sqlalchemy import delete, func, select
|
| 8 |
from sqlalchemy.dialects.postgresql import insert
|
| 9 |
|
| 10 |
from src.db.postgres.connection import AsyncSessionLocal
|
|
|
|
| 49 |
"data": stmt.excluded.data,
|
| 50 |
"schema_version": stmt.excluded.schema_version,
|
| 51 |
"generated_at": stmt.excluded.generated_at,
|
| 52 |
+
"updated_at": func.now(),
|
| 53 |
},
|
| 54 |
)
|
| 55 |
await session.execute(stmt)
|