Introduce API Redesign

neo4j/_async/driver.py

@@ -393,11 +393,11 @@ async def supports_multi_db(self):
             await session._connect(READ_ACCESS)
             return session._connection.supports_multiple_databases
 
-    async def query(self, query, parameters=None,
-                    database=None,
-                    cluster_member_access=CLUSTER_AUTO_ACCESS,
-                    skip_records=False,
-                    **kwargs):
+    async def query(
+            self, query, parameters=None, database=None,
+            cluster_member_access=CLUSTER_AUTO_ACCESS, skip_records=False,
+            **kwargs
+    ):
         """
         Run a Cypher query within an managed transaction.
 
@@ -431,10 +431,11 @@ async def query(self, query, parameters=None,
                 **kwargs
             )
 
-    async def execute(self, transaction_function, *args,
-                      database=None,
-                      cluster_member_access=CLUSTER_AUTO_ACCESS,
-                      **kwargs):
+    async def execute(
+            self, transaction_function, *args,
+            database=None, cluster_member_access=CLUSTER_AUTO_ACCESS,
+            **kwargs
+    ):
         """Execute a unit of work in a managed transaction.
 
         This transaction will automatically be committed unless an exception

neo4j/_async/work/session.py

@@ -246,10 +246,11 @@ async def run(self, query, parameters=None, **kwargs):
 
         return self._auto_result
 
-    async def query(self, query, parameters=None,
-                    cluster_member_access=CLUSTER_AUTO_ACCESS,
-                    skip_records=False,
-                    **kwargs):
+    async def query(
+        self, query, parameters=None,
+        cluster_member_access=CLUSTER_AUTO_ACCESS, skip_records=False,
+        **kwargs
+    ):
         """
         Run a Cypher query within an managed transaction.
 
@@ -275,20 +276,25 @@ async def query(self, query, parameters=None,
 
         async def job(tx, **job_kwargs):
             if skip_records:
-                result = await tx.run(query, parameters, **job_kwargs)
+                result = await tx.run(
+                    query,
+                    parameters=parameters,
+                    **job_kwargs
+                )
                 summary = await result.consume()
                 return QueryResult([], summary)
-            return await tx.query(query, parameters, **job_kwargs)
+            return await tx.query(query, parameters=parameters, **job_kwargs)
 
         return await self.execute(
             job,
             cluster_member_access=cluster_member_access,
             **kwargs
         )
 
-    async def execute(self, transaction_function, *args,
-                      cluster_member_access=CLUSTER_AUTO_ACCESS,
-                      **kwargs):
+    async def execute(
+        self, transaction_function, *args,
+        cluster_member_access=CLUSTER_AUTO_ACCESS, **kwargs
+    ):
         """Execute a unit of work in a managed transaction.
 
         This transaction will automatically be committed unless an exception

neo4j/_sync/driver.py

@@ -393,11 +393,11 @@ def supports_multi_db(self):
             session._connect(READ_ACCESS)
             return session._connection.supports_multiple_databases
 
-    def query(self, query, parameters=None,
-                    database=None,
-                    cluster_member_access=CLUSTER_AUTO_ACCESS,
-                    skip_records=False,
-                    **kwargs):
+    def query(
+            self, query, parameters=None, database=None,
+            cluster_member_access=CLUSTER_AUTO_ACCESS, skip_records=False,
+            **kwargs
+    ):
         """
         Run a Cypher query within an managed transaction.
 
@@ -431,10 +431,11 @@ def query(self, query, parameters=None,
                 **kwargs
             )
 
-    def execute(self, transaction_function, *args,
-                      database=None,
-                      cluster_member_access=CLUSTER_AUTO_ACCESS,
-                      **kwargs):
+    def execute(
+            self, transaction_function, *args,
+            database=None, cluster_member_access=CLUSTER_AUTO_ACCESS,
+            **kwargs
+    ):
         """Execute a unit of work in a managed transaction.
 
         This transaction will automatically be committed unless an exception

neo4j/_sync/work/session.py

@@ -246,10 +246,11 @@ def run(self, query, parameters=None, **kwargs):
 
         return self._auto_result
 
-    def query(self, query, parameters=None,
-                    cluster_member_access=CLUSTER_AUTO_ACCESS,
-                    skip_records=False,
-                    **kwargs):
+    def query(
+        self, query, parameters=None,
+        cluster_member_access=CLUSTER_AUTO_ACCESS, skip_records=False,
+        **kwargs
+    ):
         """
         Run a Cypher query within an managed transaction.
 
@@ -275,20 +276,25 @@ def query(self, query, parameters=None,
 
         def job(tx, **job_kwargs):
             if skip_records:
-                result = tx.run(query, parameters, **job_kwargs)
+                result = tx.run(
+                    query,
+                    parameters=parameters,
+                    **job_kwargs
+                )
                 summary = result.consume()
                 return QueryResult([], summary)
-            return tx.query(query, parameters, **job_kwargs)
+            return tx.query(query, parameters=parameters, **job_kwargs)
 
         return self.execute(
             job,
             cluster_member_access=cluster_member_access,
             **kwargs
         )
 
-    def execute(self, transaction_function, *args,
-                      cluster_member_access=CLUSTER_AUTO_ACCESS,
-                      **kwargs):
+    def execute(
+        self, transaction_function, *args,
+        cluster_member_access=CLUSTER_AUTO_ACCESS, **kwargs
+    ):
         """Execute a unit of work in a managed transaction.
 
         This transaction will automatically be committed unless an exception