diff --git a/rare/lgndr/manager.py b/rare/lgndr/manager.py index a8f0bbed..b73c855e 100644 --- a/rare/lgndr/manager.py +++ b/rare/lgndr/manager.py @@ -1,21 +1,21 @@ +import logging import os import time -import logging - from multiprocessing import Queue as MPQueue from multiprocessing.shared_memory import SharedMemory from sys import exit from threading import Condition, Thread +import legendary.downloader.mp.manager from legendary.downloader.mp.workers import DLWorker, FileWorker from legendary.models.downloading import ChunkTask, SharedMemorySegment, TerminateWorkerTask -import legendary.downloader.mp.manager from .downloading import UIUpdate class DLManager(legendary.downloader.mp.manager.DLManager): # fmt: off + # @staticmethod def run_real(self): self.shared_memory = SharedMemory(create=True, size=self.max_shared_memory) self.log.debug(f'Created shared memory of size: {self.shared_memory.size / 1024 / 1024:.02f} MiB')