diff --git a/econtext/master.py b/econtext/master.py index 279ed2e0..677065a2 100644 --- a/econtext/master.py +++ b/econtext/master.py @@ -222,11 +222,13 @@ class Broker(econtext.core.Broker): """Listen on `address `for connections from newly spawned contexts.""" self._listener = Listener(self, address, backlog) - def GetLocal(self, name='default'): + def GetLocal(self, name='default', python_path=None): """Get the named context running on the local machine, creating it if it does not exist.""" context = Context(self, name) context.stream = LocalStream(context) + if python_path: + context.stream.python_path = python_path context.stream.Connect() return self.Register(context)