I am a new user to beaver. I am shipping my logs to a remote redis-server using ssh tunneling.

I had beaver running overnight, and came to find this error in the beaver log, and a stop to logs shipping. There doesn't seem to be an issue on the redis side, I'm not sure how this could be happening to beaver..

[2015-08-06 11:05:23,810] INFO Starting queue consumer
[2015-08-06 11:05:23,833] ERROR Main consumer queue is full
Process Process-1:7968:
Traceback (most recent call last):
File "/usr/lib64/python2.6/multiprocessing/process.py", line 232, in _bootstrap
self.run()
File "/usr/lib64/python2.6/multiprocessing/process.py", line 88, in run
self._target(_self._args, *_self._kwargs)
File "/root/.local/lib/python2.6/site-packages/Beaver-34.0.0-py2.6.egg/beaver/run_queue.py", line 56, in run_queue
if command == 'callback':
UnboundLocalError: local variable 'command' referenced before assignment
[2015-08-06 11:05:28,817] INFO Starting queue consumer
[2015-08-06 11:05:28,835] ERROR Main consumer queue is full
Process Process-1:7969:
Traceback (most recent call last):
File "/usr/lib64/python2.6/multiprocessing/process.py", line 232, in _bootstrap
self.run()
File "/usr/lib64/python2.6/multiprocessing/process.py", line 88, in run
self._target(_self._args, *_self._kwargs)
File "/root/.local/lib/python2.6/site-packages/Beaver-34.0.0-py2.6.egg/beaver/run_queue.py", line 56, in run_queue
if command == 'callback':
UnboundLocalError: local variable 'command' referenced before assignment