diff --git a/src/discordbot/discordbot.py b/src/discordbot/discordbot.py
index 29620f3..54f976f 100644
--- a/src/discordbot/discordbot.py
+++ b/src/discordbot/discordbot.py
@@ -77,10 +77,14 @@ async def update_database():
                 stream_name = value['name']
                 stream_start_at = value['start_at']       
                 if stream_start_at == 'now':
-                    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,))
-                    return
-                
+                    try:
+                        job = scheduler.get_job('announce_live_channel')
+                        if not job:
+                            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,))
+                            return
+                    except JobLookupError:
+                        pass
             try:
                 job = scheduler.get_job('announce_live_channel')
                 if job:
@@ -88,10 +92,8 @@ async def update_database():
                     live_channel = bot.get_channel(announce_channel_id)
                     logger_discord.info(f'{stream_name} finished')
                     await live_channel.send(f'{stream_name} finished')
-                else:
-                    return
             except JobLookupError:
-                return
+                pass
 
 async def announce_live_channel(stream_name):
     if announce_channel_id == 'disabled':