diff --git a/legendary/downloader/workers.py b/legendary/downloader/workers.py index 9744430..1f3c20f 100644 --- a/legendary/downloader/workers.py +++ b/legendary/downloader/workers.py @@ -42,7 +42,7 @@ class DLWorker(Process): continue if job.kill: # let worker die - self.log.info(f'[{self.name}] Queue Empty, waiting for more...') + self.log.info(f'[{self.name}] Worker received kill signal, shutting down...') break tries = 0 @@ -99,6 +99,8 @@ class DLWorker(Process): self.o_q.put(DownloaderTaskResult(success=False, chunk_guid=job.guid, shm=job.shm, url=job.url)) continue + self.shm.close() + class FileWorker(Process): def __init__(self, queue, out_queue, base_path, shm, cache_path=None):