From 889daa840acc234e68fb4fcb3da9d15003a3b0ef Mon Sep 17 00:00:00 2001 From: Andreas Wicenec Date: Wed, 15 Dec 2021 17:46:55 +0800 Subject: [PATCH] Last fixes. Multi nodes is working now. --- daliuge-engine/dlg/deploy/remotes.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/daliuge-engine/dlg/deploy/remotes.py b/daliuge-engine/dlg/deploy/remotes.py index 202b96665..f885d30fa 100644 --- a/daliuge-engine/dlg/deploy/remotes.py +++ b/daliuge-engine/dlg/deploy/remotes.py @@ -46,7 +46,7 @@ def __init__(self, options, my_ip): def _get_ip_from_name(self, hostname): rx = re.compile("^(?:[0-9]{1,3}\.){3}[0-9]{1,3}$") - if re.match(hostname): # already an IP?? + if rx.match(hostname): # already an IP?? return hostname else: return socket.gethostbyname(hostname) @@ -55,10 +55,10 @@ def _set_world(self, rank, size, sorted_peers): """Called by subclasses""" self.rank = rank self.size = size - if len(set(self.sorted_peers)) != self.size: + if len(set(sorted_peers)) != self.size: raise RuntimeError("More than one task started per node, cannot continue") # convert nodes to IP addresses if hostnames - self.sorted_peers = list(map(lambda x:self.get_ip_from_name, + self.sorted_peers = list(map(lambda x:self._get_ip_from_name(x), sorted_peers)) nm_range = self._nm_range() if nm_range[0] == nm_range[1]: