Skip to content

Commit

Permalink
Fix search for content without media type
Browse files Browse the repository at this point in the history
  • Loading branch information
volbil committed Sep 24, 2024
1 parent 156c8eb commit 52daae6
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 13 deletions.
8 changes: 3 additions & 5 deletions app/sync/search/anime.py
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,6 @@ def anime_to_document(anime: Anime):
async def anime_documents(session: AsyncSession, limit: int, offset: int):
anime_list = await session.scalars(
select(Anime)
.filter(Anime.media_type != None) # noqa: E711
.filter(Anime.deleted == False) # noqa: E712
.filter(Anime.needs_search_update == True) # noqa: E712
.options(
Expand All @@ -142,7 +141,6 @@ async def anime_documents(session: AsyncSession, limit: int, offset: int):
async def anime_document_ids_delete(session: AsyncSession):
anime_list = await session.scalars(
select(Anime)
.filter(Anime.media_type != None) # noqa: E711
.filter(Anime.deleted == True) # noqa: E712
.filter(Anime.needs_search_update == True) # noqa: E712
)
Expand All @@ -159,9 +157,9 @@ async def anime_document_ids_delete(session: AsyncSession):

async def anime_documents_total(session: AsyncSession):
return await session.scalar(
select(func.count(Anime.id))
.filter(Anime.media_type != None) # noqa: E711
.filter(Anime.needs_search_update == True) # noqa: E712
select(func.count(Anime.id)).filter(
Anime.needs_search_update == True # noqa: E712
)
)


Expand Down
7 changes: 3 additions & 4 deletions app/sync/search/manga.py
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,6 @@ async def manga_documents(session: AsyncSession, limit: int, offset: int):
async def manga_document_ids_delete(session: AsyncSession):
manga_list = await session.scalars(
select(Manga)
.filter(Manga.media_type != None) # noqa: E711
.filter(Manga.deleted == True) # noqa: E712
.filter(Manga.needs_search_update == True) # noqa: E712
)
Expand All @@ -124,9 +123,9 @@ async def manga_document_ids_delete(session: AsyncSession):

async def manga_documents_total(session: AsyncSession):
return await session.scalar(
select(func.count(Manga.id))
.filter(Manga.media_type != None) # noqa: E711
.filter(Manga.needs_search_update == True) # noqa: E712
select(func.count(Manga.id)).filter(
Manga.needs_search_update == True # noqa: E712
)
)


Expand Down
7 changes: 3 additions & 4 deletions app/sync/search/novel.py
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,6 @@ async def novel_documents(session: AsyncSession, limit: int, offset: int):
async def novel_document_ids_delete(session: AsyncSession):
novel_list = await session.scalars(
select(Novel)
.filter(Novel.media_type != None) # noqa: E711
.filter(Novel.deleted == True) # noqa: E712
.filter(Novel.needs_search_update == True) # noqa: E712
)
Expand All @@ -124,9 +123,9 @@ async def novel_document_ids_delete(session: AsyncSession):

async def novel_documents_total(session: AsyncSession):
return await session.scalar(
select(func.count(Novel.id))
.filter(Novel.media_type != None) # noqa: E711
.filter(Novel.needs_search_update == True) # noqa: E712
select(func.count(Novel.id)).filter(
Novel.needs_search_update == True # noqa: E712
)
)


Expand Down

0 comments on commit 52daae6

Please sign in to comment.