diff --git a/alembic_db/versions/0001_assets.py b/alembic_db/versions/0001_assets.py index ec41ee6c1..8499306ba 100644 --- a/alembic_db/versions/0001_assets.py +++ b/alembic_db/versions/0001_assets.py @@ -23,7 +23,6 @@ def upgrade() -> None: sa.Column("size_bytes", sa.BigInteger(), nullable=False, server_default="0"), sa.Column("mime_type", sa.String(length=255), nullable=True), sa.Column("created_at", sa.DateTime(timezone=False), nullable=False), - sa.Column("updated_at", sa.DateTime(timezone=False), nullable=False), sa.CheckConstraint("size_bytes >= 0", name="ck_assets_size_nonneg"), ) op.create_index("ix_assets_mime_type", "assets", ["mime_type"]) diff --git a/app/database/models.py b/app/database/models.py index f2972b00a..ea3f4970d 100644 --- a/app/database/models.py +++ b/app/database/models.py @@ -47,9 +47,6 @@ class Asset(Base): created_at: Mapped[datetime] = mapped_column( DateTime(timezone=False), nullable=False, default=utcnow ) - updated_at: Mapped[datetime] = mapped_column( - DateTime(timezone=False), nullable=False, default=utcnow - ) infos: Mapped[list["AssetInfo"]] = relationship( "AssetInfo", diff --git a/app/database/services.py b/app/database/services.py index 5c3bbe42a..d1b85e160 100644 --- a/app/database/services.py +++ b/app/database/services.py @@ -85,7 +85,7 @@ async def ingest_fs_asset( Upsert Asset identity row + cache state pointing at local file. Always: - - Insert Asset if missing; else update size_bytes (and updated_at) if different. + - Insert Asset if missing; - Insert AssetCacheState if missing; else update mtime_ns if different. Optionally (when info_name is provided): @@ -123,7 +123,6 @@ async def ingest_fs_asset( size_bytes=int(size_bytes), mime_type=mime_type, created_at=datetime_now, - updated_at=datetime_now, ) ) await session.flush() @@ -140,7 +139,6 @@ async def ingest_fs_asset( existing.mime_type = mime_type changed = True if changed: - existing.updated_at = datetime_now out["asset_updated"] = True else: logging.error("Asset %s not found after PK conflict; skipping update.", asset_hash)