| 12345678910111213141516171819202122232425262728 |
- ###############################################################################
- # Modification of concurrent.futures.Future
- #
- # author: Thomas Moreau and Olivier Grisel
- #
- # adapted from concurrent/futures/_base.py (17/02/2017)
- # * Do not use yield from
- # * Use old super syntax
- #
- # Copyright 2009 Brian Quinlan. All Rights Reserved.
- # Licensed to PSF under a Contributor Agreement.
- from concurrent.futures import Future as _BaseFuture
- from concurrent.futures._base import LOGGER
- # To make loky._base.Future instances awaitable by concurrent.futures.wait,
- # derive our custom Future class from _BaseFuture. _invoke_callback is the only
- # modification made to this class in loky.
- # TODO investigate why using `concurrent.futures.Future` directly does not
- # always work in our test suite.
- class Future(_BaseFuture):
- def _invoke_callbacks(self):
- for callback in self._done_callbacks:
- try:
- callback(self)
- except BaseException:
- LOGGER.exception(f"exception calling callback for {self!r}")
|
