This commit is contained in:
Egor Matveev 2022-05-02 22:11:06 +03:00
parent dd857de7d2
commit ad0e4a641c

View File

@ -37,6 +37,7 @@ class MessagingSupport(BaseCommand):
except OperationalError: except OperationalError:
print("Failed to connect to database, restarting...") print("Failed to connect to database, restarting...")
send_to_queue(self.queue_name, data) send_to_queue(self.queue_name, data)
raise
def handle(self, *args, **options): def handle(self, *args, **options):
if self.queue_name is None: if self.queue_name is None: