diff --git a/tubearchivist/home/tasks.py b/tubearchivist/home/tasks.py
index 6eebf1df..fffb97c1 100644
--- a/tubearchivist/home/tasks.py
+++ b/tubearchivist/home/tasks.py
@@ -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)