lukas.pupkalipinski/Aniworld
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

back to single thread

Browse Source
This commit is contained in:
Lukas Pupka-Lipinski 2025-05-18 19:28:56 +02:00
parent aade02d763
commit cb6e74199b
2 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Loader.py
View File

@ -40,7 +40,7 @@ def download(anime: Anime): # pylint: disable=too-many-branches
"yt-dlp", "yt-dlp",
episode.get_direct_link(anime.provider, anime.language), episode.get_direct_link(anime.provider, anime.language),
"--fragment-retries", "infinite", "--fragment-retries", "infinite",
"--concurrent-fragments", "4", #"--concurrent-fragments", "4",
"-o", output_path, "-o", output_path,
"--quiet", "--quiet",
"--no-warnings" "--no-warnings"

30
main.py
View File

@ -168,21 +168,21 @@ class Loader:
logging.error(f"Error downloading episode {episode} of season {season} for anime {key}: {e}") logging.error(f"Error downloading episode {episode} of season {season} for anime {key}: {e}")
# Using ThreadPoolExecutor to run downloads in parallel # Using ThreadPoolExecutor to run downloads in parallel
with ThreadPoolExecutor(max_workers=2) as executor: # Adjust number of workers as needed #with ThreadPoolExecutor(max_workers=1) as executor: # Adjust number of workers as needed
for folder, mp4_files in result: for folder, mp4_files in result:
try: try:
key = self.__check_and_generate_key(folder) key = self.__check_and_generate_key(folder)
missings = self.__GetMissingEpisodesAndSeason(key, mp4_files) missings = self.__GetMissingEpisodesAndSeason(key, mp4_files)
for season, missing_episodes in missings: for season, missing_episodes in missings:
logging.info(f"Missing episodes for {key}\nSeason {str(season)}: Episodes: " + ",".join(f"{''.join(str(v))}" for v in missing_episodes)) logging.info(f"Missing episodes for {key}\nSeason {str(season)}: Episodes: " + ",".join(f"{''.join(str(v))}" for v in missing_episodes))
for episode in missing_episodes: for episode in missing_episodes:
executor.submit(download_episode, folder, season, episode, key) #executor.submit(download_episode, folder, season, episode, key)
#download_episode(folder, season, episode, key) download_episode(folder, season, episode, key)
except NoKeyFoundException as nkfe: except NoKeyFoundException as nkfe:
noKeyFound_logger.error(f"Error processing folder '{folder}': {nkfe}") noKeyFound_logger.error(f"Error processing folder '{folder}': {nkfe}")
except Exception as e: except Exception as e:
error_logger.error(f"Unexpected error processing folder '{folder}': {e} \n {traceback.format_exc()}") error_logger.error(f"Unexpected error processing folder '{folder}': {e} \n {traceback.format_exc()}")
continue continue
# Read the base directory from an environment variable # Read the base directory from an environment variable
directory_to_search = os.getenv("ANIME_DIRECTORY", "\\\\sshfs.r\\ubuntu@192.168.178.43\\media\\serien\\Serien") directory_to_search = os.getenv("ANIME_DIRECTORY", "\\\\sshfs.r\\ubuntu@192.168.178.43\\media\\serien\\Serien")