async conflict

backend/Qdrant.py

@@ -43,7 +43,7 @@ class QdrantManager:
             vector_size = 384
             
             # Create collection with vector configuration
-            await self.qdrant_client.create_collection(
+            self.qdrant_client.create_collection(
                 collection_name=collection_name,
                 vectors_config=models.VectorParams(
                     size=vector_size,
@@ -62,7 +62,7 @@ class QdrantManager:
             }
             
             for field_name, schema_type in payload_indices.items():
-                await self.qdrant_client.create_payload_index(
+                self.qdrant_client.create_payload_index(
                     collection_name=collection_name,
                     field_name=field_name,
                     field_schema=schema_type

backend/vector_store.py

@@ -64,7 +64,7 @@ class VectorStore:
         """
         try:
             # Try to get collection info - this is more reliable than just listing collections
-            collection_info = await self.client.get_collection(self.collection_name)
+            collection_info = self.client.get_collection(self.collection_name)
             print(f"Collection '{self.collection_name}' exists and is accessible")
             return True
         except Exception as e:
@@ -85,7 +85,7 @@ class VectorStore:
             vector_size = 384
             
             # Create collection with vector configuration
-            await self.client.create_collection(
+            self.client.create_collection(
                 collection_name=self.collection_name,
                 vectors_config=models.VectorParams(
                     size=vector_size,
@@ -108,7 +108,7 @@ class VectorStore:
             
             for field_name, schema_type in payload_indices.items():
                 try:
-                    await self.client.create_payload_index(
+                    self.client.create_payload_index(
                         collection_name=self.collection_name,
                         field_name=field_name,
                         field_schema=schema_type
@@ -201,7 +201,7 @@ class VectorStore:
                 )
                 
                 # Store in Qdrant
-                result = await self.client.upsert(
+                result = self.client.upsert(
                     collection_name=self.collection_name,
                     points=[point]
                 )
@@ -244,7 +244,7 @@ class VectorStore:
             query_embedding = self.embedding_model.encode([query])[0]
             
             # Search in Qdrant
-            results = await self.client.search(
+            results = self.client.search(
                 collection_name=self.collection_name,
                 query_vector=query_embedding.tolist(),
                 limit=limit
@@ -269,7 +269,7 @@ class VectorStore:
     async def get_collection_info(self) -> Dict:
         """Get information about the collection"""
         try:
-            collection_info = await self.client.get_collection(self.collection_name)
+            collection_info = self.client.get_collection(self.collection_name)
             return {
                 "name": collection_info.config.name,
                 "vector_size": collection_info.config.params.vectors.size,