test
This commit is contained in:
parent
f6acd67738
commit
70126acdf2
|
@ -24,6 +24,7 @@ def moderation_worker():
|
||||||
result = redis_moderation.blpop('queue:msgs_to_check')
|
result = redis_moderation.blpop('queue:msgs_to_check')
|
||||||
try:
|
try:
|
||||||
msg, tag = json.loads(result[1])
|
msg, tag = json.loads(result[1])
|
||||||
|
print(tag)
|
||||||
_, categories = check_moderation_endpoint(msg)
|
_, categories = check_moderation_endpoint(msg)
|
||||||
redis_moderation.rpush('queue:flagged_categories', json.dumps((tag, categories)))
|
redis_moderation.rpush('queue:flagged_categories', json.dumps((tag, categories)))
|
||||||
except:
|
except:
|
||||||
|
|
Reference in New Issue