diff options
| author | Josh Morman <jmorman@gnuradio.org> | 2021-11-24 12:46:14 -0500 |
|---|---|---|
| committer | mormj <34754695+mormj@users.noreply.github.com> | 2021-11-24 14:41:53 -0500 |
| commit | e776d673aa51b5ef19e16cfb6d22098c0b14a679 (patch) | |
| tree | 04805a8ffdc89d571560db03585f9663ad19d821 /gr-zeromq/python/zeromq/rpc_manager.py | |
| parent | 99c987395704fc99ccea4ccdc30ee4dc14ab1ef3 (diff) | |
zeromq: pep8 formatting
Signed-off-by: Josh Morman <jmorman@gnuradio.org>
Diffstat (limited to 'gr-zeromq/python/zeromq/rpc_manager.py')
| -rw-r--r-- | gr-zeromq/python/zeromq/rpc_manager.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/gr-zeromq/python/zeromq/rpc_manager.py b/gr-zeromq/python/zeromq/rpc_manager.py index 389214bb41..ba7a0ac86d 100644 --- a/gr-zeromq/python/zeromq/rpc_manager.py +++ b/gr-zeromq/python/zeromq/rpc_manager.py @@ -58,7 +58,7 @@ class rpc_manager(object): self.rep_socket.send(pmt.serialize_str(pmt.to_pmt(reply))) def start_watcher(self): - self.watcher_thread = threading.Thread(target=self.watcher,args=()) + self.watcher_thread = threading.Thread(target=self.watcher, args=()) self.watcher_thread.daemon = True self.watcher_thread.start() @@ -69,7 +69,7 @@ class rpc_manager(object): def request(self, id_str, args=None): socks = dict(self.poller_req_out.poll(10)) if socks.get(self.req_socket) == zmq.POLLOUT: - self.req_socket.send(pmt.serialize_str(pmt.to_pmt((id_str,args)))) + self.req_socket.send(pmt.serialize_str(pmt.to_pmt((id_str, args)))) socks = dict(self.poller_req_in.poll(10)) if socks.get(self.req_socket) == zmq.POLLIN: reply = pmt.to_python(pmt.deserialize_str(self.req_socket.recv())) |