(self)
| 3457 | return self.cluster.executor.submit(fn, *args, **kwargs) |
| 3458 | |
| 3459 | def get_pool_state(self): |
| 3460 | return dict((host, pool.get_state()) for host, pool in tuple(self._pools.items())) |
| 3461 | |
| 3462 | def get_pools(self): |
| 3463 | return self._pools.values() |