conductor-checkpoint-msg_0127MeSvxWk8BLXjB5k3wDJY

This commit is contained in:
Daniel Chalef 2025-10-30 07:22:58 -07:00
parent afd83123fe
commit 8332ec3aa9

View file

@ -235,9 +235,13 @@ class GraphitiService:
max_coroutines=self.semaphore_limit,
)
# Test connection (only Neo4j has verify_connectivity)
# Test connection based on database provider
if self.config.database.provider.lower() == 'neo4j':
await self.client.driver.client.verify_connectivity() # type: ignore
elif self.config.database.provider.lower() == 'falkordb':
# FalkorDB uses ping() method to test connectivity
self.client.driver.client.ping() # type: ignore
# KuzuDB doesn't need a connectivity test (in-memory)
# Build indices
await self.client.build_indices_and_constraints()