From 871e41aec6225c6c2c1b019db482fbd94b214c32 Mon Sep 17 00:00:00 2001 From: bigcat88 Date: Wed, 27 Aug 2025 21:36:31 +0300 Subject: [PATCH] removed not needed "refcount" column --- alembic_db/versions/0001_assets.py | 2 -- app/database/models.py | 1 - app/database/services.py | 3 +-- 3 files changed, 1 insertion(+), 5 deletions(-) diff --git a/alembic_db/versions/0001_assets.py b/alembic_db/versions/0001_assets.py index 18b1c71a1..ec41ee6c1 100644 --- a/alembic_db/versions/0001_assets.py +++ b/alembic_db/versions/0001_assets.py @@ -22,11 +22,9 @@ def upgrade() -> None: sa.Column("hash", sa.String(length=256), primary_key=True), sa.Column("size_bytes", sa.BigInteger(), nullable=False, server_default="0"), sa.Column("mime_type", sa.String(length=255), nullable=True), - sa.Column("refcount", sa.BigInteger(), nullable=False, server_default="0"), 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"), - sa.CheckConstraint("refcount >= 0", name="ck_assets_refcount_nonneg"), ) op.create_index("ix_assets_mime_type", "assets", ["mime_type"]) diff --git a/app/database/models.py b/app/database/models.py index 87aa942ed..f2972b00a 100644 --- a/app/database/models.py +++ b/app/database/models.py @@ -44,7 +44,6 @@ class Asset(Base): hash: Mapped[str] = mapped_column(String(256), primary_key=True) size_bytes: Mapped[int] = mapped_column(BigInteger, nullable=False, default=0) mime_type: Mapped[str | None] = mapped_column(String(255)) - refcount: Mapped[int] = mapped_column(BigInteger, nullable=False, default=0) created_at: Mapped[datetime] = mapped_column( DateTime(timezone=False), nullable=False, default=utcnow ) diff --git a/app/database/services.py b/app/database/services.py index 66d519032..5c3bbe42a 100644 --- a/app/database/services.py +++ b/app/database/services.py @@ -89,7 +89,7 @@ async def ingest_fs_asset( - Insert AssetCacheState if missing; else update mtime_ns if different. Optionally (when info_name is provided): - - Create an AssetInfo (no refcount changes). + - Create an AssetInfo. - Link provided tags to that AssetInfo. * If the require_existing_tags=True, raises ValueError if any tag does not exist in `tags` table. * If False (default), create unknown tags. @@ -122,7 +122,6 @@ async def ingest_fs_asset( hash=asset_hash, size_bytes=int(size_bytes), mime_type=mime_type, - refcount=0, created_at=datetime_now, updated_at=datetime_now, )