From 0b0b612c3343eaf0eff86d39b4a4769c52146d1a Mon Sep 17 00:00:00 2001 From: schneefux Date: Sun, 19 Mar 2017 15:39:17 +0100 Subject: kill process when the worker crashes, increase batch limit --- api.py | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/api.py b/api.py index b75beb9..b1321d5 100644 --- a/api.py +++ b/api.py @@ -80,15 +80,13 @@ class Compiler(joblib.worker.Worker): async def startup(): - for _ in range(1): - worker = Compiler() - await worker.connect(db_config, queue_db) - await worker.setup() - await worker.start(batchlimit=750) + worker = Compiler() + await worker.connect(db_config, queue_db) + await worker.setup() + await worker.run(batchlimit=1000) logging.basicConfig(level=logging.DEBUG) loop = asyncio.get_event_loop() loop.run_until_complete(startup()) -loop.run_forever() -- cgit v1.3.1