Add new_report amqp message

2026-04-27 03:00:12 -04:00 · 2015-03-12 17:28:01 -06:00
parent f4109ba70f
commit 1089c951b3
1 changed files with 2 additions and 0 deletions
--- a/r2/r2/lib/db/queries.py
+++ b/r2/r2/lib/db/queries.py
@@ -1527,6 +1527,8 @@ def new_report(thing, report_rel):
        elif isinstance(thing, Message):
            m.insert(get_user_reported_messages(reporter_id), [report_rel])

+    amqp.add_item("new_report", thing._fullname)
+

 def clear_reports(things, rels):
    query_cache_deletes = []