CancelledError is now always considered "quiet" (and
concurrent.futures.CancelledError is no longer the same as
asyncio.CancelledError).
# under the License.
import collections
-from concurrent.futures import CancelledError
import datetime
import types
if timeout is None:
return fut
else:
- timeout_fut = gen.with_timeout(
- timeout, fut, quiet_exceptions=(CancelledError,)
- )
+ timeout_fut = gen.with_timeout(timeout, fut)
# This is a slightly clumsy workaround for the fact that
# gen.with_timeout doesn't cancel its futures. Cancelling
# fut will remove it from the waiters list.