(n=DEFAULT_ITS, loglevel='CRITICAL')
| 73 | |
| 74 | |
| 75 | def bench_work(n=DEFAULT_ITS, loglevel='CRITICAL'): |
| 76 | loglevel = os.environ.get('BENCH_LOGLEVEL') or loglevel |
| 77 | if loglevel: |
| 78 | app.log.setup_logging_subsystem(loglevel=loglevel) |
| 79 | worker = app.WorkController(concurrency=15, |
| 80 | queues=['bench.worker']) |
| 81 | |
| 82 | try: |
| 83 | print('-- starting worker') |
| 84 | worker.start() |
| 85 | except SystemExit: |
| 86 | assert sum(worker.state.total_count.values()) == n + 1 |
| 87 | raise |
| 88 | |
| 89 | |
| 90 | def bench_both(n=DEFAULT_ITS): |
no test coverage detected