From e70dad61caefd3f85c29f30798cd1472e03cb4cf Mon Sep 17 00:00:00 2001 From: schneefux Date: Sun, 19 Mar 2017 15:40:21 +0100 Subject: kill process when the worker crashes --- api.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/api.py b/api.py index f2158ec..d8daf46 100644 --- a/api.py +++ b/api.py @@ -117,11 +117,10 @@ async def startup(): worker = Cruncher() await worker.connect(db_config, queue_db) await worker.setup() - await worker.start(batchlimit=1) + await worker.run(batchlimit=1) logging.basicConfig(level=logging.DEBUG) loop = asyncio.get_event_loop() loop.run_until_complete(startup()) -loop.run_forever() -- cgit v1.3.1