tubearchivist
/
tubearchivist
mirror of https://github.com/tubearchivist/tubearchivist.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

use task notification for already running

This commit is contained in:
simon 2023-03-18 18:00:38 +07:00
parent f194259ab3
commit 73c82a91c0
No known key found for this signature in database
GPG Key ID: 2C15AA5E89985DD4
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tubearchivist/home/tasks.py
View File

@ -149,13 +149,7 @@ def update_subscribed(self):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] rescan already running")
message = {
"status": "message:rescan",
"level": "error",
"title": "Rescanning channels and playlists.",
"message": "Rescan already in progress.",
}
RedisArchivist().set_message("message:rescan", message, expire=True)
self.send_progress("Rescan already in progress.")
return
manager.init(self)
@ -171,6 +165,7 @@ def download_pending(self, from_queue=True):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] download queue already running")
self.send_progress("Download Queue is already running.")
return
manager.init(self)
@ -200,6 +195,7 @@ def check_reindex(self, data=False, extract_videos=False):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] reindex queue is already running")
self.send_progress("Reindex Queue is already running.")
return
manager.init(self)
@ -218,6 +214,7 @@ def run_manual_import(self):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] manual import is already running")
self.send_progress("Manual import is already running.")
return
manager.init(self)
@ -230,6 +227,7 @@ def run_backup(self, reason="auto"):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] backup is already running")
self.send_progress("Backup is already running.")
return
manager.init(self)
@ -242,6 +240,7 @@ def run_restore_backup(self, filename):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] restore is already running")
self.send_progress("Restore is already running.")
return
manager.init(self)
@ -278,6 +277,7 @@ def rescan_filesystem(self):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] filesystem rescan already running")
self.send_progress("Filesystem Rescan is already running.")
return
manager.init(self)
@ -291,6 +291,7 @@ def thumbnail_check(self):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] thumbnail check is already running")
self.send_progress("Thumbnail check is already running.")
return
manager.init(self)
@ -303,6 +304,7 @@ def re_sync_thumbs(self):
manager = TaskManager()
if manager.is_pending(self):
print(f"[task][{self.name}] thumb re-embed is already running")
self.send_progress("Thumbnail re-embed is already running.")
return
manager.init(self)