| 170 | |
| 171 | |
| 172 | class ConcurrentExecutorFutureResults(ConcurrentExecutorListResults): |
| 173 | def __init__(self, session, statements_and_params, execution_profile, future): |
| 174 | super().__init__(session, statements_and_params, execution_profile) |
| 175 | self.future = future |
| 176 | |
| 177 | def _put_result(self, result, idx, success): |
| 178 | super()._put_result(result, idx, success) |
| 179 | with self._condition: |
| 180 | if self._current == self._exec_count: |
| 181 | if self._exception and self._fail_fast: |
| 182 | self.future.set_exception(self._exception) |
| 183 | else: |
| 184 | sorted_results = [r[1] for r in sorted(self._results_queue)] |
| 185 | self.future.set_result(sorted_results) |
| 186 | |
| 187 | |
| 188 | def execute_concurrent_async( |
no outgoing calls
no test coverage detected