diff --git a/src/backend/services/web/risk/handlers/risk.py b/src/backend/services/web/risk/handlers/risk.py
index 9fb8b819..dc11433d 100644
--- a/src/backend/services/web/risk/handlers/risk.py
+++ b/src/backend/services/web/risk/handlers/risk.py
@@ -171,7 +171,7 @@ def create_risk(self, event: dict) -> (bool, Risk):
                     & Q(
                         ~Q(status=RiskStatus.CLOSED)
                         | Q(
-                            event_end_time__lte=datetime.datetime.fromtimestamp(
+                            event_end_time__gte=datetime.datetime.fromtimestamp(
                                 event["event_time"] / 1000, tz=timezone.get_default_timezone()
                             )
                         )