Lower buffer size

This commit is contained in:
simon 2019-12-19 11:15:43 -05:00
parent 3a3fe1f546
commit fcb2ce8b68

2
run.py
View File

@ -105,7 +105,7 @@ def serialize(thing):
}
@buffered(batch_size=10000, flush_on_exit=True)
@buffered(batch_size=5000, flush_on_exit=True)
def _publish_buffered(items):
buckets = defaultdict(list)
for item in items: