Merge cluster to master #3
|
@ -50,7 +50,7 @@ class RedisPriorityQueue:
|
|||
b = self.redis.hget('queued_ip_count', item[1])
|
||||
self.decrement_ip_count(client_ip, 'queued_ip_count')
|
||||
a = self.redis.hget('queued_ip_count', item[1])
|
||||
|
||||
|
||||
print(item[1], a, b)
|
||||
|
||||
return item
|
||||
|
|
|
@ -52,7 +52,6 @@ def moderation_worker():
|
|||
_, categories = check_moderation_endpoint(msg)
|
||||
redis_moderation.rpush('queue:flagged_categories', json.dumps((tag, categories)))
|
||||
except:
|
||||
print(result)
|
||||
traceback.print_exc()
|
||||
continue
|
||||
|
||||
|
|
Reference in New Issue