|
| 1 | +import time |
1 | 2 | from codegate.codegate_logging import setup_logging
|
2 | 3 | from codegate.inference.inference_engine import LlamaCppInferenceEngine
|
3 | 4 | from weaviate.classes.config import DataType
|
@@ -45,24 +46,22 @@ def __init__(self, data_path='./weaviate_data'):
|
45 | 46 | weaviate_client.connect()
|
46 | 47 | self.setup_schema(weaviate_client)
|
47 | 48 | except Exception as e:
|
48 |
| - self.__logger.error(f"Failed to connect or setup schema: {str(e)}") |
| 49 | + self.__logger.error(f"Failed to connect or setup schema: {str(e)}") |
49 | 50 | finally:
|
50 |
| - print("i close") |
51 |
| - weaviate_client.close() |
| 51 | + try: |
| 52 | + weaviate_client.close() |
| 53 | + except Exception as e: |
| 54 | + self.__logger.info(f"Failed to close client: {str(e)}") |
52 | 55 | else:
|
53 | 56 | self.__logger.error("Could not find client, skipping schema setup.")
|
54 | 57 |
|
55 | 58 | def setup_schema(self, client):
|
56 |
| - print("in setup schema") |
57 | 59 | for class_config in self.schema_config:
|
58 |
| - print("i get config") |
59 | 60 | if not client.collections.exists(class_config['name']):
|
60 |
| - print("i create") |
61 | 61 | client.collections.create(class_config['name'],
|
62 | 62 | properties=class_config['properties'])
|
63 | 63 | self.__logger.info(
|
64 | 64 | f"Weaviate schema for class {class_config['name']} setup complete.")
|
65 |
| - print("finish schema") |
66 | 65 |
|
67 | 66 | async def search(self, query: str, limit=5, distance=0.3) -> list[object]:
|
68 | 67 | """
|
@@ -100,4 +99,7 @@ async def search(self, query: str, limit=5, distance=0.3) -> list[object]:
|
100 | 99 | self.__logger.error(f"Error during search: {str(e)}")
|
101 | 100 | return []
|
102 | 101 | finally:
|
103 |
| - weaviate_client.close() |
| 102 | + try: |
| 103 | + weaviate_client.close() |
| 104 | + except Exception as e: |
| 105 | + self.__logger.info(f"Failed to close client: {str(e)}") |
0 commit comments