Set router sock opt

materialsproject · Sep 26, 2022 · ac1d70b · ac1d70b
1 parent efd7c1d
commit ac1d70b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/maggma/cli/distributed.py b/src/maggma/cli/distributed.py
@@ -45,6 +45,7 @@ def manager(
 
     logger.info(f"Binding to Manager URL {url}:{port}")
     context = zmq.Context()
+    context.setsockopt(opt=zmq.SocketOption.ROUTER_MANDATORY, value=1)
     socket = context.socket(zmq.ROUTER)
     socket.bind(f"{url}:{port}")