tubearchivist/tubearchivist-frontend
1
0
Fork 0
mirror of https://github.com/tubearchivist/tubearchivist-frontend.git synced 2024-11-22 11:50:14 +00:00
Code Issues Projects Releases Wiki Activity

fix linting

Browse Source
This commit is contained in:
simon 2021-10-08 15:10:44 +07:00
parent 64ccd3830e
commit 563222a26e
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tubearchivist/home/tasks.py
View File

@ -14,7 +14,7 @@ from home.src.index_management import backup_all_indexes, restore_from_backup
from home.src.reindex import ( from home.src.reindex import (
ManualImport, ManualImport,
reindex_old_documents, reindex_old_documents,
scan_filesystem scan_filesystem,
) )
CONFIG = AppConfig().config CONFIG = AppConfig().config
@ -45,7 +45,6 @@ def update_subscribed():
@shared_task @shared_task
def download_pending(): def download_pending():
"""download latest pending videos""" """download latest pending videos"""
have_lock = False have_lock = False
my_lock = RedisArchivist().get_lock("downloading") my_lock = RedisArchivist().get_lock("downloading")
@ -66,11 +65,9 @@ def download_pending():
@shared_task @shared_task
def download_single(youtube_id): def download_single(youtube_id):
"""start download single video now""" """start download single video now"""
queue = RedisQueue("dl_queue") queue = RedisQueue("dl_queue")
queue.add_priority(youtube_id) queue.add_priority(youtube_id)
print("Added to queue with priority: " + youtube_id) print("Added to queue with priority: " + youtube_id)
# start queue if needed # start queue if needed
have_lock = False have_lock = False
my_lock = RedisArchivist().get_lock("downloading") my_lock = RedisArchivist().get_lock("downloading")
@ -105,7 +102,6 @@ def check_reindex():
@shared_task @shared_task
def run_manual_import(): def run_manual_import():
"""called from settings page, to go through import folder""" """called from settings page, to go through import folder"""
print("starting media file import") print("starting media file import")
have_lock = False have_lock = False
my_lock = RedisArchivist().get_lock("manual_import") my_lock = RedisArchivist().get_lock("manual_import")
@ -162,5 +158,5 @@ def kill_dl(task_id):
@shared_task @shared_task
def rescan_filesystem(): def rescan_filesystem():
"""check the media folder for missmatches""" """check the media folder for mismatches"""
scan_filesystem() scan_filesystem()