(self, exception)
| 165 | return return_value |
| 166 | |
| 167 | def _log_and_set_exception(self, exception): |
| 168 | # If an exception is ever thrown than set the exception for the |
| 169 | # entire TransferFuture. |
| 170 | logger.debug("Exception raised.", exc_info=True) |
| 171 | self._transfer_coordinator.set_exception(exception) |
| 172 | |
| 173 | def _main(self, **kwargs): |
| 174 | """The method that will be ran in the executor |
no test coverage detected