summaryrefslogtreecommitdiff
path: root/rpc
diff options
context:
space:
mode:
Diffstat (limited to 'rpc')
-rw-r--r--rpc/rpc.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/rpc/rpc.py b/rpc/rpc.py
index 51f8feb..cc2336e 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -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):