Compare commits
2 Commits
0ec120e08f
...
e44a8190d0
| Author | SHA1 | Date | |
|---|---|---|---|
| e44a8190d0 | |||
| 94720f2d61 |
4
.gitignore
vendored
4
.gitignore
vendored
@@ -4,6 +4,7 @@
|
|||||||
/src/__pycache__/*
|
/src/__pycache__/*
|
||||||
/src/__pycache__/
|
/src/__pycache__/
|
||||||
/.vs/*
|
/.vs/*
|
||||||
|
/.venv/*
|
||||||
/src/Temp/*
|
/src/Temp/*
|
||||||
/src/Loaders/__pycache__/*
|
/src/Loaders/__pycache__/*
|
||||||
/src/Loaders/provider/__pycache__/*
|
/src/Loaders/provider/__pycache__/*
|
||||||
@@ -81,4 +82,5 @@ Temp/
|
|||||||
temp/
|
temp/
|
||||||
tmp/
|
tmp/
|
||||||
*.tmp
|
*.tmp
|
||||||
.coverage
|
.coverage
|
||||||
|
.venv/bin/dotenv
|
||||||
|
|||||||
7
.vscode/settings.json
vendored
7
.vscode/settings.json
vendored
@@ -1,8 +1,11 @@
|
|||||||
{
|
{
|
||||||
"python.defaultInterpreterPath": "C:\\Users\\lukas\\anaconda3\\envs\\AniWorld\\python.exe",
|
"python.defaultInterpreterPath": "${workspaceFolder}/.venv/bin/python",
|
||||||
"python.terminal.activateEnvironment": true,
|
"python.terminal.activateEnvironment": true,
|
||||||
"python.condaPath": "C:\\Users\\lukas\\anaconda3\\Scripts\\conda.exe",
|
|
||||||
"python.terminal.activateEnvInCurrentTerminal": true,
|
"python.terminal.activateEnvInCurrentTerminal": true,
|
||||||
|
"terminal.integrated.env.linux": {
|
||||||
|
"VIRTUAL_ENV": "${workspaceFolder}/.venv",
|
||||||
|
"PATH": "${workspaceFolder}/.venv/bin:${env:PATH}"
|
||||||
|
},
|
||||||
"python.linting.enabled": true,
|
"python.linting.enabled": true,
|
||||||
"python.linting.flake8Enabled": true,
|
"python.linting.flake8Enabled": true,
|
||||||
"python.linting.pylintEnabled": true,
|
"python.linting.pylintEnabled": true,
|
||||||
|
|||||||
@@ -118,99 +118,3 @@ For each task completed:
|
|||||||
---
|
---
|
||||||
|
|
||||||
## TODO List:
|
## TODO List:
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
fix: download not working:
|
|
||||||
|
|
||||||
elf.\_progress_service.update_progress(
|
|
||||||
|
|
||||||
File "/app/src/server/services/progress_service.py", line 369, in update_progress
|
|
||||||
|
|
||||||
raise ProgressServiceError(
|
|
||||||
|
|
||||||
src.server.services.progress_service.ProgressServiceError: Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
2026-03-11 15:15:42 [info ] Processing next item from queue item_id=108 remaining=2 serie=I Was Reincarnated as the 7th Prince So I Can Take My Time Perfecting My Magical Ability
|
|
||||||
|
|
||||||
2026-03-11 15:15:42 [error ] Error in queue processing loop error=Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
Traceback (most recent call last):
|
|
||||||
|
|
||||||
File "/app/src/server/services/download_service.py", line 716, in \_process_queue
|
|
||||||
|
|
||||||
await self._progress_service.update_progress(
|
|
||||||
|
|
||||||
File "/app/src/server/services/progress_service.py", line 369, in update_progress
|
|
||||||
|
|
||||||
raise ProgressServiceError(
|
|
||||||
|
|
||||||
src.server.services.progress_service.ProgressServiceError: Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
2026-03-11 15:15:43 [info ] Processing next item from queue item_id=109 remaining=1 serie=I Was Reincarnated as the 7th Prince So I Can Take My Time Perfecting My Magical Ability
|
|
||||||
|
|
||||||
2026-03-11 15:15:43 [error ] Error in queue processing loop error=Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
Traceback (most recent call last):
|
|
||||||
|
|
||||||
File "/app/src/server/services/download_service.py", line 716, in \_process_queue
|
|
||||||
|
|
||||||
await self._progress_service.update_progress(
|
|
||||||
|
|
||||||
File "/app/src/server/services/progress_service.py", line 369, in update_progress
|
|
||||||
|
|
||||||
raise ProgressServiceError(
|
|
||||||
|
|
||||||
src.server.services.progress_service.ProgressServiceError: Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
2026-03-11 15:15:44 [info ] Processing next item from queue item_id=110 remaining=0 serie=I Was Reincarnated as the 7th Prince So I Can Take My Time Perfecting My Magical Ability
|
|
||||||
|
|
||||||
2026-03-11 15:15:44 [error ] Error in queue processing loop error=Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
Traceback (most recent call last):
|
|
||||||
|
|
||||||
File "/app/src/server/services/download_service.py", line 716, in \_process_queue
|
|
||||||
|
|
||||||
await self._progress_service.update_progress(
|
|
||||||
|
|
||||||
File "/app/src/server/services/progress_service.py", line 369, in update_progress
|
|
||||||
|
|
||||||
raise ProgressServiceError(
|
|
||||||
|
|
||||||
src.server.services.progress_service.ProgressServiceError: Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
2026-03-11 15:15:45 [info ] Queue processing completed - all items processed
|
|
||||||
|
|
||||||
ERROR: Task exception was never retrieved
|
|
||||||
|
|
||||||
future: <Task finished name='Task-16373' coro=<DownloadService.\_process_queue() done, defined at /app/src/server/services/download_service.py:688> exception=ProgressServiceError("Progress with id 'download_queue' not found")>
|
|
||||||
|
|
||||||
Traceback (most recent call last):
|
|
||||||
|
|
||||||
File "/app/src/server/services/download_service.py", line 755, in \_process_queue
|
|
||||||
|
|
||||||
await self._progress_service.complete_progress(
|
|
||||||
|
|
||||||
File "/app/src/server/services/progress_service.py", line 446, in complete_progress
|
|
||||||
|
|
||||||
raise ProgressServiceError(
|
|
||||||
|
|
||||||
src.server.services.progress_service.ProgressServiceError: Progress with id 'download_queue' not found
|
|
||||||
|
|
||||||
2026-03-11 15:15:46 [info ] Queue processing completed - all items processed
|
|
||||||
|
|
||||||
ERROR: Task exception was never retrieved
|
|
||||||
|
|
||||||
future: <Task finished name='Task-16313' coro=<DownloadService.\_process_queue() done, defined at /app/src/server/services/download_service.py:688> exception=ProgressServiceError("Progress with id 'download_queue' not found")>
|
|
||||||
|
|
||||||
Traceback (most recent call last):
|
|
||||||
|
|
||||||
File "/app/src/server/services/download_service.py", line 755, in \_process_queue
|
|
||||||
|
|
||||||
await self._progress_service.complete_progress(
|
|
||||||
|
|
||||||
File "/app/src/server/services/progress_service.py", line 446, in complete_progress
|
|
||||||
|
|
||||||
raise ProgressServiceError(
|
|
||||||
|
|
||||||
src.server.services.progress_service.ProgressServiceError: Progress with id 'download_queue' not found
|
|
||||||
|
|||||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@@ -834,9 +834,9 @@ async def add_series(
|
|||||||
# Step F: Scan missing episodes immediately if background loader is not running
|
# Step F: Scan missing episodes immediately if background loader is not running
|
||||||
# Uses existing SerieScanner and AnimeService sync to avoid duplicates
|
# Uses existing SerieScanner and AnimeService sync to avoid duplicates
|
||||||
try:
|
try:
|
||||||
loader_running = (
|
loader_running = bool(
|
||||||
background_loader.worker_task is not None
|
background_loader.worker_tasks
|
||||||
and not background_loader.worker_task.done()
|
and any(not t.done() for t in background_loader.worker_tasks)
|
||||||
)
|
)
|
||||||
if (
|
if (
|
||||||
not loader_running
|
not loader_running
|
||||||
|
|||||||
@@ -36,6 +36,7 @@ def mock_anime_service():
|
|||||||
"""Mock AnimeService."""
|
"""Mock AnimeService."""
|
||||||
service = AsyncMock()
|
service = AsyncMock()
|
||||||
service.sync_episodes_to_db = AsyncMock()
|
service.sync_episodes_to_db = AsyncMock()
|
||||||
|
service.sync_single_series_after_scan = AsyncMock()
|
||||||
return service
|
return service
|
||||||
|
|
||||||
|
|
||||||
@@ -600,7 +601,7 @@ class TestScanMissingEpisodes:
|
|||||||
await background_loader_service._scan_missing_episodes(task, mock_db)
|
await background_loader_service._scan_missing_episodes(task, mock_db)
|
||||||
|
|
||||||
assert task.progress["episodes"] is True
|
assert task.progress["episodes"] is True
|
||||||
background_loader_service.anime_service.sync_episodes_to_db.assert_called_once_with("test")
|
background_loader_service.anime_service.sync_single_series_after_scan.assert_called_once_with("test")
|
||||||
|
|
||||||
@pytest.mark.asyncio
|
@pytest.mark.asyncio
|
||||||
async def test_scan_missing_episodes_no_scanner(self, background_loader_service):
|
async def test_scan_missing_episodes_no_scanner(self, background_loader_service):
|
||||||
|
|||||||
Reference in New Issue
Block a user