github/reddit
1
1
Fork 0
mirror of https://github.com/reddit-archive/reddit.git synced 2026-04-27 03:00:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

commentstree_q: Add a min size for fastlane.

Browse Source
This commit is contained in:
Ricky Ramirez
2016-01-05 16:30:45 -08:00
parent 4ef212de9f
commit dcf0db2a4f
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
r2/r2/lib/db/queries.py
View File

@@ -1718,10 +1718,13 @@ def run_commentstree(qname="commentstree_q", limit=100):
if comments:
add_comments(comments)
min_size = 0
# High velocity threads put additional pressure on Cassandra.
if qname == "commentstree_fastlane_q":
limit = max(1000, limit)
amqp.handle_items(qname, _run_commentstree, limit = limit)
min_size = min(1000, limit)
amqp.handle_items(qname, _run_commentstree, limit=limit, min_size=min_size)
def _by_type(items):