diff --git a/SprintLib/queue.py b/SprintLib/queue.py
index 72c447c..cd9322f 100644
--- a/SprintLib/queue.py
+++ b/SprintLib/queue.py
@@ -37,6 +37,7 @@ class MessagingSupport(BaseCommand):
         except OperationalError:
             print("Failed to connect to database, restarting...")
             send_to_queue(self.queue_name, data)
+            raise
 
     def handle(self, *args, **options):
         if self.queue_name is None: