(self, kwargs)
| 148 | self._transfer_coordinator.announce_done() |
| 149 | |
| 150 | def _execute_main(self, kwargs): |
| 151 | # Do not display keyword args that should not be printed, especially |
| 152 | # if they are going to make the logs hard to follow. |
| 153 | params_to_exclude = ['data'] |
| 154 | kwargs_to_display = self._get_kwargs_with_params_to_exclude( |
| 155 | kwargs, params_to_exclude |
| 156 | ) |
| 157 | # Log what is about to be executed. |
| 158 | logger.debug(f"Executing task {self} with kwargs {kwargs_to_display}") |
| 159 | |
| 160 | return_value = self._main(**kwargs) |
| 161 | # If the task is the final task, then set the TransferFuture's |
| 162 | # value to the return value from main(). |
| 163 | if self._is_final: |
| 164 | self._transfer_coordinator.set_result(return_value) |
| 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 |
no test coverage detected