less debug output
This commit is contained in:
parent
41d90e1736
commit
fa9482de48
1 changed files with 4 additions and 1 deletions
|
@ -70,6 +70,8 @@ class Node(Thread):
|
||||||
else:
|
else:
|
||||||
if not self._q.qsize():
|
if not self._q.qsize():
|
||||||
time.sleep(5)
|
time.sleep(5)
|
||||||
|
else:
|
||||||
|
time.sleep(0.1)
|
||||||
self.queue(action[0], *action[1])
|
self.queue(action[0], *action[1])
|
||||||
else:
|
else:
|
||||||
logger.debug('unknown action %s', action)
|
logger.debug('unknown action %s', action)
|
||||||
|
@ -83,7 +85,8 @@ class Node(Thread):
|
||||||
self._q.put('ping')
|
self._q.put('ping')
|
||||||
|
|
||||||
def queue(self, action, *args):
|
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])
|
self._q.put([action, args])
|
||||||
|
|
||||||
def _call(self, action, *args):
|
def _call(self, action, *args):
|
||||||
|
|
Loading…
Reference in a new issue