From fcb2ce8b68f9e42e53e9ba33e89c2c0cc8af9be0 Mon Sep 17 00:00:00 2001 From: simon Date: Thu, 19 Dec 2019 11:15:43 -0500 Subject: [PATCH] Lower buffer size --- run.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/run.py b/run.py index 40dfb97..e242035 100755 --- a/run.py +++ b/run.py @@ -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: