Skip to content

Commit 77e1cae

Browse files
committed
Refactored download_queue.py (#200)
- Async adding of downloads to queue - Multiple concurrent direct downloads - Start next download while current one is post-processing
1 parent 27f1517 commit 77e1cae

File tree

10 files changed

+481
-379
lines changed

10 files changed

+481
-379
lines changed

Kapowarr.py

+7-5
Original file line numberDiff line numberDiff line change
@@ -13,10 +13,12 @@
1313
from backend.base.definitions import Constants, RestartVersion
1414
from backend.base.helpers import check_python_version, get_python_exe
1515
from backend.base.logging import LOGGER, setup_logging
16+
from backend.features.download_queue import DownloadHandler
17+
from backend.features.tasks import TaskHandler
1618
from backend.implementations.flaresolverr import FlareSolverr
1719
from backend.internals.db import close_all_db, set_db_location, setup_db
1820
from backend.internals.server import SERVER, handle_restart_version
19-
from frontend.api import Settings, download_handler, task_handler
21+
from backend.internals.settings import Settings
2022

2123

2224
def _main(
@@ -59,13 +61,13 @@ def _main(
5961
flaresolverr = FlareSolverr()
6062
SERVER.set_url_base(settings.url_base)
6163

62-
download_handler.create_download_folder()
63-
6464
if settings.flaresolverr_base_url:
6565
flaresolverr.enable_flaresolverr(settings.flaresolverr_base_url)
6666

67-
download_handler.load_download_thread.start()
68-
task_handler.handle_intervals()
67+
download_handler = DownloadHandler()
68+
download_handler.load_downloads()
69+
task_handler = TaskHandler()
70+
task_handler.handle_intervals()
6971

7072
try:
7173
# =================

0 commit comments

Comments
 (0)