(self)
| 1161 | pool.create(w) |
| 1162 | |
| 1163 | def test_Pool_pool_no_sem(self): |
| 1164 | w = Mock() |
| 1165 | w.pool_cls.uses_semaphore = False |
| 1166 | components.Pool(w).create(w) |
| 1167 | assert w.process_task is w._process_task |
| 1168 | |
| 1169 | def test_Pool_create(self): |
| 1170 | from kombu.asynchronous.semaphore import LaxBoundedSemaphore |