(self, w)
| 40 | w.autoscaler = None |
| 41 | |
| 42 | def create(self, w): |
| 43 | scaler = w.autoscaler = self.instantiate( |
| 44 | w.autoscaler_cls, |
| 45 | w.pool, w.max_concurrency, w.min_concurrency, |
| 46 | worker=w, mutex=DummyLock() if w.use_eventloop else None, |
| 47 | ) |
| 48 | return scaler if not w.use_eventloop else None |
| 49 | |
| 50 | def register_with_event_loop(self, w, hub): |
| 51 | w.consumer.on_task_message.add(w.autoscaler.maybe_scale) |