kill process when the worker crashesrelease/1.5.0

1 files changed, 1 insertions, 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()