(self, n)
| 122 | self.pool.grow(n) |
| 123 | |
| 124 | def _shrink(self, n): |
| 125 | info('Scaling down %s processes.', n) |
| 126 | try: |
| 127 | self.pool.shrink(n) |
| 128 | except ValueError: |
| 129 | debug("Autoscaler won't scale down: all processes busy.") |
| 130 | except Exception as exc: |
| 131 | error('Autoscaler: scale_down: %r', exc, exc_info=True) |
| 132 | |
| 133 | def _update_consumer_prefetch_count(self, new_max): |
| 134 | diff = new_max - self.max_concurrency |