test
This commit is contained in:
parent
62eb0196cc
commit
ca1baa4870
|
@ -20,6 +20,7 @@ def start_moderation_workers(num_workers):
|
||||||
|
|
||||||
|
|
||||||
def moderation_worker():
|
def moderation_worker():
|
||||||
|
print('moderator started')
|
||||||
while True:
|
while True:
|
||||||
result = redis_moderation.blpop('queue:msgs_to_check')
|
result = redis_moderation.blpop('queue:msgs_to_check')
|
||||||
try:
|
try:
|
||||||
|
|
Reference in New Issue