diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-09 20:28:15 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-09 20:28:15 +0100 |
| commit | d0c3cb553bc009bd4e10941203e1cd5b922c3978 (patch) | |
| tree | 8294d11de6e30ec4b4e43c35f2948fff841ee8d3 | |
| parent | 8a18e44d9bccbe1f85d940af886edc04b9936392 (diff) | |
| download | compiler-d0c3cb553bc009bd4e10941203e1cd5b922c3978.tar.gz compiler-d0c3cb553bc009bd4e10941203e1cd5b922c3978.zip | |
start more workers with smaller batches
| -rw-r--r-- | api.py | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -82,11 +82,11 @@ class Compiler(joblib.worker.Worker): async def startup(): - for _ in range(1): + for _ in range(3): worker = Compiler() await worker.connect(db_config, queue_db) await worker.setup() - await worker.start(batchlimit=750) + await worker.start(batchlimit=20) logging.basicConfig( |
