Skip to content

Commit 9044e46

Browse files
committed
Add last sync column
1 parent cc9d1d9 commit 9044e46

File tree

2 files changed

+44
-0
lines changed

2 files changed

+44
-0
lines changed

src/infrastructure/db/models.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,9 @@ class Source(Base):
2121
onupdate=func.now(),
2222
nullable=False,
2323
)
24+
last_synced_at = Column(
25+
DateTime(timezone=True), server_default=func.now(), nullable=False
26+
)
2427

2528
chunks = relationship("Chunk", back_populates="source")
2629

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
"""add sync date
2+
3+
Revision ID: 4fcfc019db9d
4+
Revises: dc327596a170
5+
Create Date: 2025-04-25 23:52:19.810725
6+
7+
"""
8+
9+
from typing import Sequence, Union
10+
11+
from alembic import op
12+
import sqlalchemy as sa
13+
14+
15+
# revision identifiers, used by Alembic.
16+
revision: str = "4fcfc019db9d"
17+
down_revision: Union[str, None] = "dc327596a170"
18+
branch_labels: Union[str, Sequence[str], None] = None
19+
depends_on: Union[str, Sequence[str], None] = None
20+
21+
22+
def upgrade() -> None:
23+
"""Upgrade schema."""
24+
# ### commands auto generated by Alembic - please adjust! ###
25+
op.add_column(
26+
"sources",
27+
sa.Column(
28+
"last_synced_at",
29+
sa.DateTime(timezone=True),
30+
server_default=sa.text("now()"),
31+
nullable=False,
32+
),
33+
)
34+
# ### end Alembic commands ###
35+
36+
37+
def downgrade() -> None:
38+
"""Downgrade schema."""
39+
# ### commands auto generated by Alembic - please adjust! ###
40+
op.drop_column("sources", "last_synced_at")
41+
# ### end Alembic commands ###

0 commit comments

Comments
 (0)