File tree Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -766,9 +766,18 @@ def recursively_start_schedulers(identity, depth):
766
766
outgoing_id1 = identity * 2 + 1
767
767
outgoing_id2 = outgoing_id1 + 1
768
768
is_leaf = depth == self .broadcast_scheduler_depth
769
+ is_root = depth == 0
770
+
771
+ # FIXME: use localhost, not client ip for internal communication
772
+ # this will still be localhost anyway for the most common cases
773
+ # of localhost or */0.0.0.0
774
+ in_addr = self .client_url (BroadcastScheduler .port_name , identity )
775
+ if not is_root :
776
+ # non-root schedulers connect, so they need a disambiguated url
777
+ in_addr = disambiguate_url (in_addr )
769
778
770
779
scheduler_args = dict (
771
- in_addr = self . client_url ( BroadcastScheduler . port_name , identity ) ,
780
+ in_addr = in_addr ,
772
781
mon_addr = monitor_url ,
773
782
not_addr = disambiguate_url (self .client_url ('notification' )),
774
783
reg_addr = disambiguate_url (self .client_url ('registration' )),
You can’t perform that action at this time.
0 commit comments