Process task by sending it to the pool of workers.
(self, req)
| 221 | return self._quick_acquire(self._process_task, req) |
| 222 | |
| 223 | def _process_task(self, req): |
| 224 | """Process task by sending it to the pool of workers.""" |
| 225 | try: |
| 226 | req.execute_using_pool(self.pool) |
| 227 | except TaskRevokedError: |
| 228 | try: |
| 229 | self._quick_release() # Issue 877 |
| 230 | except AttributeError: |
| 231 | pass |
| 232 | |
| 233 | def signal_consumer_close(self): |
| 234 | try: |