We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 27e9565 commit 8b762daCopy full SHA for 8b762da
nodestream_plugin_neo4j/neo4j_database.py
@@ -84,9 +84,6 @@ def driver(self):
84
self.acquire_driver()
85
return self._driver
86
87
- def session(self) -> AsyncSession:
88
- return self.driver.session(database=self.database_name)
89
-
90
def log_query_start(self, query: Query):
91
self.logger.info(
92
"Executing Cypher Query to Neo4j",
@@ -142,3 +139,6 @@ async def execute(
142
139
143
140
if attempts >= self.max_retry_attempts:
144
141
raise e
+
+ def session(self) -> AsyncSession:
+ return self.driver.session(database=self.database_name)
0 commit comments