diff --git a/src/clients/qdrant_client.py b/src/clients/qdrant_client.py
index 93e3d1c..61a20a1 100644
--- a/src/clients/qdrant_client.py
+++ b/src/clients/qdrant_client.py
@@ -137,7 +137,9 @@ class QdrantClientWrapper:
             )
 
         collection_name = self.get_collection_name(user)
-        await self.ensure_collection(user)
+        # Ensure the tenant-scoped collection (passing the raw user here used
+        # to create a stray collection named after the bare user string).
+        await self.ensure_collection(collection_name)
 
         points = []
         for i, (chunk, embedding) in enumerate(zip(chunks, embeddings)):