Cutlery/Kyoo
1
0
Fork 0
mirror of https://github.com/zoriya/Kyoo.git synced 2025-06-15 11:34:17 -04:00
Code Issues Packages Projects Releases Wiki Activity

Run monitor before scan

Browse Source
This commit is contained in:
Zoe Roux 2024-02-26 23:40:03 +01:00
parent faf8832572
commit fc7926c2cc
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
scanner/scanner/__init__.py
View File

@ -1,4 +1,5 @@
async def main(): async def main():
import asyncio
import os import os
import logging import logging
import sys import sys
@ -38,8 +39,9 @@ async def main():
) as client: ) as client:
try: try:
scanner = Scanner(client, languages=languages.split(","), api_key=api_key) scanner = Scanner(client, languages=languages.split(","), api_key=api_key)
await scanner.scan(path) await asyncio.gather(
logging.info("Scan finished. Starting to monitor...") monitor(path, scanner),
await monitor(path, scanner) scanner.scan(path),
)
except ProviderError as e: except ProviderError as e:
logging.error(e) logging.error(e)

1
scanner/scanner/scanner.py
View File

@ -54,6 +54,7 @@ class Scanner:
# We batch videos by 20 because too mutch at once kinda DDOS everything. # We batch videos by 20 because too mutch at once kinda DDOS everything.
for group in batch(iter(videos), 20): for group in batch(iter(videos), 20):
await asyncio.gather(*map(self.identify, group)) await asyncio.gather(*map(self.identify, group))
logging.info("Scan finished.")
async def get_registered_paths(self) -> List[str]: async def get_registered_paths(self) -> List[str]:
paths = None paths = None