()
| 9 | |
| 10 | |
| 11 | def create_db_client() -> AgnosticDatabase: |
| 12 | global _db |
| 13 | connection_string = os.getenv("IQENGINE_METADATA_DB_CONNECTION_STRING") |
| 14 | _db = AsyncIOMotorClient(connection_string)["IQEngine"] |
| 15 | return _db |
| 16 | |
| 17 | |
| 18 | def create_in_memory_db_client() -> AgnosticDatabase: |