The method that will be ran in the executor This method must be implemented by subclasses from Task. main() can be implemented with any arguments decided upon by the subclass.
(self, **kwargs)
| 171 | self._transfer_coordinator.set_exception(exception) |
| 172 | |
| 173 | def _main(self, **kwargs): |
| 174 | """The method that will be ran in the executor |
| 175 | |
| 176 | This method must be implemented by subclasses from Task. main() can |
| 177 | be implemented with any arguments decided upon by the subclass. |
| 178 | """ |
| 179 | raise NotImplementedError('_main() must be implemented') |
| 180 | |
| 181 | def _wait_on_dependent_futures(self): |
| 182 | # Gather all of the futures into that main() depends on. |