diff --git a/src/services/scheduler_sync/synchronizer.py b/src/services/scheduler_sync/synchronizer.py
index 368ca02..cc2180c 100644
--- a/src/services/scheduler_sync/synchronizer.py
+++ b/src/services/scheduler_sync/synchronizer.py
@@ -1,5 +1,6 @@
 from asyncio import sleep
 import logging
+from datetime import datetime
 
 from services.scheduler_sync.twitch_events import get_twitch_events, TwitchEvent
 from services.scheduler_sync.discord_events import (
@@ -25,6 +26,9 @@ async def add_events(
     discord_events_ids = [event[0] for event in discord_events]
 
     for (uid, event) in twitch_events:
+        if event.start_at > datetime.now(event.start_at.tzinfo):
+            continue
+
         if uid not in discord_events_ids:
             create_event = CreateDiscordEvent.parse_from_twitch_event(event, twitch_channel_name)
             await create_discord_event(guild_id, create_event)
diff --git a/src/services/scheduler_sync/twitch_events.py b/src/services/scheduler_sync/twitch_events.py
index 2486b0d..6c933da 100644
--- a/src/services/scheduler_sync/twitch_events.py
+++ b/src/services/scheduler_sync/twitch_events.py
@@ -71,7 +71,7 @@ async def get_twitch_events(twitch_channel_id: str) -> list[TwitchEvent]:
                 else:
                     raise ValueError("Invalid repeat rule")
 
-            if (datetime.now(event.start_at.tzinfo) - event.start_at).seconds > 60 or event.repeat_rule:
+            if event.start_at > datetime.now(event.start_at.tzinfo) or event.repeat_rule:
                 events.append(event)
 
         return events