@@ -26,7 +26,7 @@ class HeartBeatBuffer(threading.Thread):
_prev_success_task_count = 0
_prev_failed_task_count = 0
- def __init__(self, redis_key):
+ def __init__(self, redis_key=None):
if not hasattr(self, "_items_queue"):
super(HeartBeatBuffer, self).__init__()
