diff options
| -rw-r--r-- | api.py | 10 |
1 files changed, 4 insertions, 6 deletions
@@ -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() |
