From bdc3a4aea0365efd796991e7e00a877a7c8413d1 Mon Sep 17 00:00:00 2001 From: maxDorninger <97409287+maxDorninger@users.noreply.github.com> Date: Tue, 24 Jun 2025 19:25:30 +0200 Subject: [PATCH] add movie tasks to scheduled tasks --- media_manager/main.py | 9 ++++++--- media_manager/movies/service.py | 2 +- media_manager/tv/service.py | 2 +- 3 files changed, 8 insertions(+), 5 deletions(-) diff --git a/media_manager/main.py b/media_manager/main.py index ed9b07f..5b20714 100644 --- a/media_manager/main.py +++ b/media_manager/main.py @@ -5,6 +5,7 @@ from logging.config import dictConfig from pathlib import Path from pythonjsonlogger.json import JsonFormatter + LOGGING_CONFIG = { "version": 1, "disable_existing_loggers": False, @@ -52,9 +53,10 @@ import media_manager.movies.router as movies_router # noqa: E402 import media_manager.tv.router as tv_router # noqa: E402 from media_manager.tv.service import ( # noqa: E402 auto_download_all_approved_season_requests, - import_all_torrents, + import_all_show_torrents, update_all_non_ended_shows_metadata, ) +from media_manager.movies.service import import_all_movie_torrents, update_all_movies_metadata import shutil # noqa: E402 from fastapi import FastAPI # noqa: E402 @@ -81,13 +83,14 @@ else: def hourly_tasks(): log.info(f"Hourly tasks are running at {datetime.now()}") auto_download_all_approved_season_requests() - import_all_torrents() + import_all_show_torrents() + import_all_movie_torrents() def weekly_tasks(): log.info(f"Weekly tasks are running at {datetime.now()}") update_all_non_ended_shows_metadata() - + update_all_movies_metadata() scheduler = BackgroundScheduler() trigger = CronTrigger(minute=0, hour="*") diff --git a/media_manager/movies/service.py b/media_manager/movies/service.py index 5349d4f..58bced9 100644 --- a/media_manager/movies/service.py +++ b/media_manager/movies/service.py @@ -577,7 +577,7 @@ def auto_download_all_approved_movie_requests() -> None: db.close() -def import_all_torrents() -> None: +def import_all_movie_torrents() -> None: db: Session = SessionLocal() movie_repository = MovieRepository(db=db) torrent_service = TorrentService(torrent_repository=TorrentRepository(db=db)) diff --git a/media_manager/tv/service.py b/media_manager/tv/service.py index 9386718..262edba 100644 --- a/media_manager/tv/service.py +++ b/media_manager/tv/service.py @@ -746,7 +746,7 @@ def auto_download_all_approved_season_requests() -> None: db.close() -def import_all_torrents() -> None: +def import_all_show_torrents() -> None: db: Session = SessionLocal() tv_repository = TvRepository(db=db) torrent_service = TorrentService(torrent_repository=TorrentRepository(db=db))