diff options
Diffstat (limited to 'rpc')
| -rw-r--r-- | rpc/rpc.py | 6 |
1 files changed, 3 insertions, 3 deletions
@@ -12,8 +12,8 @@ load_dotenv(find_dotenv()) class CortexRPC(object): def __init__(self, get_fn, set_fn, ready_fn): super().__init__() - self._get_fn = get_fn - self._set_fn = set_fn + self._get_fn = staticmethod(get_fn) + self._set_fn = staticmethod(set_fn) self.working = False self.connect(ready_fn) @@ -22,7 +22,7 @@ class CortexRPC(object): self.rpc = zerorpc.Server(self) self.rpc.bind('tcp://127.0.0.1:' + os.getenv('RPC_PORT')) gevent.spawn(self.connected) - gevent.spawn(ready_fn) + gevent.spawn(lambda: ready_fn(self)) self.rpc.run() def connected(self): |
