@@ -75,22 +75,27 @@ def NewDriver(backend, data):
7575 ** auth_token .get ("parameters" , {})
7676 )
7777 auth_token .mark_item_as_read ("parameters" , recursive = True )
78- resolver = None
78+ kwargs = {}
7979 if data ["resolverRegistered" ] or data ["domainNameResolverRegistered" ]:
80- resolver = resolution_func (backend , data ["resolverRegistered" ],
81- data ["domainNameResolverRegistered" ])
82- connection_timeout = data .get ("connectionTimeoutMs" )
83- if connection_timeout is not None :
84- connection_timeout /= 1000
85- max_transaction_retry_time = data .get ("maxTxRetryTimeMs" )
86- if max_transaction_retry_time is not None :
87- max_transaction_retry_time /= 1000
80+ kwargs ["resolver" ] = resolution_func (
81+ backend , data ["resolverRegistered" ],
82+ data ["domainNameResolverRegistered" ]
83+ )
84+ if data .get ("connectionTimeoutMs" ):
85+ kwargs ["connection_timeout" ] = data ["connectionTimeoutMs" ] / 1000
86+ if data .get ("maxTxRetryTimeMs" ):
87+ kwargs ["max_transaction_retry_time" ] = data ["maxTxRetryTimeMs" ] / 1000
88+ if data .get ("connectionAcquisitionTimeoutMs" ):
89+ kwargs ["connection_acquisition_timeout" ] = \
90+ data ["connectionAcquisitionTimeoutMs" ] / 1000
91+ if data .get ("maxConnectionPoolSize" ):
92+ kwargs ["max_connection_pool_size" ] = data ["maxConnectionPoolSize" ]
93+ if data .get ("fetchSize" ):
94+ kwargs ["fetch_size" ] = data ["fetchSize" ]
95+
8896 data .mark_item_as_read ("domainNameResolverRegistered" )
8997 driver = neo4j .GraphDatabase .driver (
90- data ["uri" ], auth = auth , user_agent = data ["userAgent" ],
91- resolver = resolver , connection_timeout = connection_timeout ,
92- fetch_size = data .get ("fetchSize" ),
93- max_transaction_retry_time = max_transaction_retry_time ,
98+ data ["uri" ], auth = auth , user_agent = data ["userAgent" ], ** kwargs
9499 )
95100 key = backend .next_key ()
96101 backend .drivers [key ] = driver
0 commit comments