@@ -563,20 +563,21 @@ def open(cls, address, *, auth, pool_config, workspace_config):
563
563
:param auth:
564
564
:param pool_config:
565
565
:param workspace_config:
566
- :param routing_context:
567
566
:return: BoltPool
568
567
"""
569
568
570
569
def opener (addr , timeout ):
571
- return Bolt .open (addr , auth = auth , timeout = timeout , routing_context = None , ** pool_config )
570
+ return Bolt .open (
571
+ addr , auth = auth , timeout = timeout , routing_context = None ,
572
+ ** pool_config
573
+ )
572
574
573
575
pool = cls (opener , pool_config , workspace_config , address )
574
576
return pool
575
577
576
578
def __init__ (self , opener , pool_config , workspace_config , address ):
577
579
super (BoltPool , self ).__init__ (opener , pool_config , workspace_config )
578
580
self .address = address
579
- self .routing_context = None
580
581
581
582
def __repr__ (self ):
582
583
return "<{} address={!r}>" .format (self .__class__ .__name__ , self .address )
@@ -610,26 +611,25 @@ def open(cls, *addresses, auth, pool_config, workspace_config, routing_context=N
610
611
routing_context ["address" ] = str (address )
611
612
612
613
def opener (addr , timeout ):
613
- return Bolt .open (addr , auth = auth , timeout = timeout , routing_context = routing_context , ** pool_config )
614
+ return Bolt .open (addr , auth = auth , timeout = timeout ,
615
+ routing_context = routing_context , ** pool_config )
614
616
615
- pool = cls (opener , pool_config , workspace_config , routing_context , address )
617
+ pool = cls (opener , pool_config , workspace_config , address )
616
618
return pool
617
619
618
- def __init__ (self , opener , pool_config , workspace_config , routing_context , address ):
620
+ def __init__ (self , opener , pool_config , workspace_config , address ):
619
621
"""
620
622
621
623
:param opener:
622
624
:param pool_config:
623
625
:param workspace_config:
624
- :param routing_context: Dictionary with routing information
625
626
:param addresses:
626
627
"""
627
628
super (Neo4jPool , self ).__init__ (opener , pool_config , workspace_config )
628
629
# Each database have a routing table, the default database is a special case.
629
630
log .debug ("[#0000] C: <NEO4J POOL> routing address %r" , address )
630
631
self .address = address
631
632
self .routing_tables = {workspace_config .database : RoutingTable (database = workspace_config .database , routers = [address ])}
632
- self .routing_context = routing_context
633
633
self .refresh_lock = Lock ()
634
634
635
635
def __repr__ (self ):
0 commit comments