More zmq updates

Author: awicenec

daliuge-engine/dlg/manager/composite_manager.py

@@ -304,7 +304,7 @@ def replicate(self, sessionId, f, action, collect=None, iterable=None, port=None
         thrExs = {}
         iterable = iterable or self._dmHosts
         port = port or self._dmPort
-        logger.debug("Hosts: %s", iterable)
+        # logger.debug("Hosts: %s", iterable)
         self._tp.map(
             functools.partial(
                 self._do_in_host, action, sessionId, thrExs, f, collect, port

daliuge-engine/dlg/rpc.py

@@ -144,7 +144,7 @@ def get_client_for_endpoint(self, host, port):
         endpoint = (host, port)
 
         with self._zrpcclient_acquisition_lock:
-            if endpoint in self._zrpcclinents:
+            if endpoint in self._zrpcclients:
                 return self._zrpcclients[endpoint]
 
             # We start the new client on its own thread so it uses gevent, etc.
@@ -215,7 +215,7 @@ def queue_request(self, client, req):
         async_result.rawlink(lambda x: self.process_response(req, x))
 
     def get_rpc_client(self, hostname, port):
-        # hostname = hostname.split(":")[0] 
+        # hostname = hostname.split(":")[0]
         client = self.get_client_for_endpoint(hostname, port)
         # No closing function since clients are long-lived
         return client, lambda: None
@@ -337,7 +337,7 @@ def __getattr__(self, name):
             self._proxy_info.port,
             self._proxy_info.session_id,
             self.uid,
-            name
+            name,
         )
 
     def __repr__(self):

daliuge-translator/test/dropmake/test_pg_gen.py

@@ -103,6 +103,7 @@ def test_metis_pgtp_gen_pg(self):
             # pgtp.json
             pgtp.to_gojs_json(visual=False)
             pg_spec = pgtp.to_pg_spec(node_list)
+
             # with open('/tmp/met_{0}_pgspec.graph'.format(lgn.split('.')[0]), 'w') as f:
             #     f.write(pg_spec)