Skip to content

Commit 686039e

Browse files
authored
Make interchange monitoring ZMQ use loopback, like other connections (#3795)
The HighThroughputExecutor assumes that the submit process and the interchange are in the same host (in the sense that the configured loopback address will work to connect from one to the other). This PR adds that assumption for connecting from the interchange to the monitoring router. Which is pretty much already a constraint: that router is launched from the submit process using Python multiprocessing and so will run on the same host as the submit process. # Changed Behaviour in-host network connections for monitoring will look a bit different, but shouldn't be a behaviour change ## Type of change - Code maintenance/cleanup
1 parent 36016ea commit 686039e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

parsl/executors/high_throughput/executor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -536,7 +536,7 @@ def _start_local_interchange_process(self) -> None:
536536
"interchange_address": self.address,
537537
"worker_ports": self.worker_ports,
538538
"worker_port_range": self.worker_port_range,
539-
"hub_address": self.hub_address,
539+
"hub_address": self.loopback_address,
540540
"hub_zmq_port": self.hub_zmq_port,
541541
"logdir": self.logdir,
542542
"heartbeat_threshold": self.heartbeat_threshold,

0 commit comments

Comments
 (0)