@@ -75,22 +75,27 @@ def NewDriver(backend, data):
75
75
** auth_token .get ("parameters" , {})
76
76
)
77
77
auth_token .mark_item_as_read ("parameters" , recursive = True )
78
- resolver = None
78
+ kwargs = {}
79
79
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
+
88
96
data .mark_item_as_read ("domainNameResolverRegistered" )
89
97
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
94
99
)
95
100
key = backend .next_key ()
96
101
backend .drivers [key ] = driver
0 commit comments