wangbo/ComfyUI
1
0
Fork 0
mirror of https://github.com/comfyanonymous/ComfyUI.git synced 2025-12-20 19:42:59 +08:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

removed non-needed code

Browse Source
This commit is contained in:
bigcat88 2025-09-14 15:14:24 +03:00
parent 47f7c7ee8c
commit 0b795dc7a7
No known key found for this signature in database
GPG Key ID: 1F0BF0EC3CF22721
2 changed files with 1 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/database/helpers/__init__.py
View File

@ -2,10 +2,8 @@ from .filters import apply_metadata_filter, apply_tag_filters
from .ownership import visible_owner_clause
from .projection import is_scalar, project_kv
from .tags import (
add_missing_tag_for_asset_hash,
add_missing_tag_for_asset_id,
ensure_tags_exist,
remove_missing_tag_for_asset_hash,
remove_missing_tag_for_asset_id,
)
@ -16,8 +14,6 @@ __all__ = [
"project_kv",
"ensure_tags_exist",
"add_missing_tag_for_asset_id",
"add_missing_tag_for_asset_hash",
"remove_missing_tag_for_asset_id",
"remove_missing_tag_for_asset_hash",
"visible_owner_clause",
]

25
app/database/helpers/tags.py
View File

@ -6,7 +6,7 @@ from sqlalchemy.dialects import sqlite as d_sqlite
from sqlalchemy.ext.asyncio import AsyncSession
from ..._assets_helpers import normalize_tags
from ..models import Asset, AssetInfo, AssetInfoTag, Tag
from ..models import AssetInfo, AssetInfoTag, Tag
from ..timeutil import utcnow
@ -77,18 +77,6 @@ async def add_missing_tag_for_asset_id(
return len(to_add)
async def add_missing_tag_for_asset_hash(
session: AsyncSession,
*,
asset_hash: str,
origin: str = "automatic",
) -> int:
asset = (await session.execute(select(Asset).where(Asset.hash == asset_hash).limit(1))).scalars().first()
if not asset:
return 0
return await add_missing_tag_for_asset_id(session, asset_id=asset.id, origin=origin)
async def remove_missing_tag_for_asset_id(
session: AsyncSession,
*,
@ -107,14 +95,3 @@ async def remove_missing_tag_for_asset_id(
)
await session.flush()
return int(res.rowcount or 0)
async def remove_missing_tag_for_asset_hash(
session: AsyncSession,
*,
asset_hash: str,
) -> int:
asset = (await session.execute(select(Asset).where(Asset.hash == asset_hash).limit(1))).scalars().first()
if not asset:
return 0
return await remove_missing_tag_for_asset_id(session, asset_id=asset.id)