diff --git a/comet/api/endpoints/stream.py b/comet/api/endpoints/stream.py
index 9f9d8bc..4ec407b 100644
--- a/comet/api/endpoints/stream.py
+++ b/comet/api/endpoints/stream.py
@@ -47,6 +47,7 @@ async def is_first_search(media_id: str):
             RETURNING 1
             """,
             params,
+            force_primary=True,
         )
         return inserted == 1
     except Exception: