diff --git a/src/server/services/scheduler/folder_rename_service.py b/src/server/services/scheduler/folder_rename_service.py index aaf9a4f..a3a8be2 100644 --- a/src/server/services/scheduler/folder_rename_service.py +++ b/src/server/services/scheduler/folder_rename_service.py @@ -363,7 +363,7 @@ def _cleanup_orphaned_folder(old_path: Path, new_path: Path, dry_run: bool = Fal return False -def _update_series_folder(db, series, new_folder: str) -> None: +async def _update_series_folder(db, series, new_folder: str) -> None: """Update AnimeSeries.folder in the database. Args: @@ -374,7 +374,7 @@ def _update_series_folder(db, series, new_folder: str) -> None: if series is None: return - AnimeSeriesService.update(db, series.id, folder=new_folder) + await AnimeSeriesService.update(db, series.id, folder=new_folder) logger.info("Updated AnimeSeries.folder: %s (id=%s)", new_folder, series.id) @@ -455,7 +455,7 @@ async def _update_database_paths( series = s break - _update_series_folder(db, series, new_folder) + await _update_series_folder(db, series, new_folder) if series is None: return diff --git a/tests/unit/test_folder_rename_service.py b/tests/unit/test_folder_rename_service.py index 910a2fb..b5c18a2 100644 --- a/tests/unit/test_folder_rename_service.py +++ b/tests/unit/test_folder_rename_service.py @@ -226,7 +226,7 @@ class TestUpdateDatabasePaths: mock_get_db.return_value.__aenter__ = AsyncMock(return_value=mock_db) mock_get_db.return_value.__aexit__ = AsyncMock(return_value=False) - mock_series_svc.get_by_key = AsyncMock(return_value=mock_series) + mock_series_svc.get_by_folder = AsyncMock(return_value=mock_series) mock_series_svc.get_all = AsyncMock(return_value=[]) mock_series_svc.update = AsyncMock(return_value=mock_series) @@ -267,7 +267,7 @@ class TestUpdateDatabasePaths: mock_get_db.return_value.__aenter__ = AsyncMock(return_value=mock_db) mock_get_db.return_value.__aexit__ = AsyncMock(return_value=False) - mock_series_svc.get_by_key = AsyncMock(return_value=mock_series) + mock_series_svc.get_by_folder = AsyncMock(return_value=mock_series) mock_series_svc.get_all = AsyncMock(return_value=[]) mock_series_svc.update = AsyncMock(return_value=mock_series)