diff -r 029b76d645dc -r a0da5075bca3 mercurial/httppeer.py --- a/mercurial/httppeer.py Wed Mar 02 10:23:53 2022 -0500 +++ b/mercurial/httppeer.py Wed Mar 02 10:24:49 2022 -0500 @@ -14,6 +14,7 @@ import socket import struct +from concurrent import futures from .i18n import _ from .pycompat import getattr from . import ( @@ -538,12 +539,12 @@ raise exception -class queuedcommandfuture(pycompat.futures.Future): +class queuedcommandfuture(futures.Future): """Wraps result() on command futures to trigger submission on call.""" def result(self, timeout=None): if self.done(): - return pycompat.futures.Future.result(self, timeout) + return futures.Future.result(self, timeout) self._peerexecutor.sendcommands()