diff options
Diffstat (limited to 'python/sandcrawler_worker.py')
| -rwxr-xr-x | python/sandcrawler_worker.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/python/sandcrawler_worker.py b/python/sandcrawler_worker.py index e18d883..d85a995 100755 --- a/python/sandcrawler_worker.py +++ b/python/sandcrawler_worker.py @@ -135,7 +135,8 @@ def run_persist_thumbnail(args): kafka_hosts=args.kafka_hosts, consume_topic=consume_topic, group="persist-pdf-thumbnail", - raw_record=True, + push_batches=False, + raw_records=True, batch_size=25, ) pusher.run() |