(self)
| 319 | worker_state.active_requests.discard(r) |
| 320 | |
| 321 | def test_active_safe(self): |
| 322 | kwargsrepr = '<anything>' |
| 323 | r = Request( |
| 324 | self.TaskMessage(self.mytask.name, id='do re mi', |
| 325 | kwargsrepr=kwargsrepr), |
| 326 | app=self.app, |
| 327 | ) |
| 328 | worker_state.active_requests.add(r) |
| 329 | try: |
| 330 | active_resp = self.panel.handle('dump_active', {'safe': True}) |
| 331 | assert active_resp[0]['kwargs'] == kwargsrepr |
| 332 | finally: |
| 333 | worker_state.active_requests.discard(r) |
| 334 | |
| 335 | def test_pool_grow(self): |
| 336 |