(self)
| 45 | ) |
| 46 | |
| 47 | def test_pool_grow(self): |
| 48 | celery = self._app.capp |
| 49 | celery.control.pool_grow = MagicMock(return_value=[{'test': 'ok'}]) |
| 50 | r = self.post('/api/worker/pool/grow/test', body={'n': 3}) |
| 51 | self.assertEqual(200, r.code) |
| 52 | celery.control.pool_grow.assert_called_once_with( |
| 53 | n=3, reply=True, destination=['test']) |
| 54 | |
| 55 | def test_pool_shrink(self): |
| 56 | celery = self._app.capp |