diff --git a/oml/nodes.py b/oml/nodes.py index 3e4c575..27d7658 100644 --- a/oml/nodes.py +++ b/oml/nodes.py @@ -70,6 +70,8 @@ class Node(Thread): else: if not self._q.qsize(): time.sleep(5) + else: + time.sleep(0.1) self.queue(action[0], *action[1]) else: logger.debug('unknown action %s', action) @@ -83,7 +85,8 @@ class Node(Thread): self._q.put('ping') def queue(self, action, *args): - logger.debug('queue node action %s->%s%s', self.user_id, action, args) + if DEBUG_NODES: + logger.debug('queue node action %s->%s%s', self.user_id, action, args) self._q.put([action, args]) def _call(self, action, *args):