diff --git a/src/discordbot/discordbot.py b/src/discordbot/discordbot.py
index 11b316c..45a7461 100644
--- a/src/discordbot/discordbot.py
+++ b/src/discordbot/discordbot.py
@@ -87,18 +87,18 @@ async def update_database():
                     # Job doesn't exist, so add it
                     logger_discord.info(f'{stream_name} live stream detected!')
                     scheduler.add_job(func=announce_live_channel, trigger='interval', seconds=60, id='announce_live_channel', args=(stream_name,))
-                    # Exit the loop since we found one
+                    # Exit since we found one
                     return
                 else:
-                    # Exit the loop since we already have a announcement job
+                    # Exit since we already have a announcement job
                     return
 
-            # Cleanup the announce job
-            if scheduler.get_job('announce_live_channel') is not None:
-                scheduler.remove_job('announce_live_channel')
-                #live_channel = bot.get_channel(announce_channel_id)
-                logger_discord.info(f'{stream_name} finished')
-                #await live_channel.send(f'{stream_name} finished')
+        # Cleanup the announce job
+        if scheduler.get_job('announce_live_channel') is not None:
+            scheduler.remove_job('announce_live_channel')
+            #live_channel = bot.get_channel(announce_channel_id)
+            logger_discord.info(f'{stream_name} finished')
+            #await live_channel.send(f'{stream_name} finished')
 
 async def announce_live_channel(stream_name):
     if announce_channel_id == 'disabled':