[gentoo-commits] proj/portage:prefix commit in: lib/portage/util/futures/

[Fabian Groffen]

commit:     fa3c93e0a0bc7a1ba6a1414137c1e569709e1b4c
Author:     Fabian Groffen <grobian <AT> gentoo <DOT> org>
AuthorDate: Mon Jan  4 11:00:50 2021 +0000
Commit:     Fabian Groffen <grobian <AT> gentoo <DOT> org>
CommitDate: Mon Jan  4 11:00:50 2021 +0000
URL:        https://gitweb.gentoo.org/proj/portage.git/commit/?id=fa3c93e0

Revert "_Retry: Use ensure_future for self._current_task"

This reverts commit 7efa7ecfe07737239be593b2c32e497cc1d2f154.

Signed-off-by: Fabian Groffen <grobian <AT> gentoo.org>

 lib/portage/util/futures/retry.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/lib/portage/util/futures/retry.py 
b/lib/portage/util/futures/retry.py
index 31cc161da..4092f60d6 100644
--- a/lib/portage/util/futures/retry.py
+++ b/lib/portage/util/futures/retry.py
@@ -1,4 +1,4 @@
-# Copyright 2018-2021 Gentoo Authors
+# Copyright 2018 Gentoo Foundation
 # Distributed under the terms of the GNU General Public License v2
 
 __all__ = (
@@ -113,7 +113,7 @@ class _Retry:
 
        def _begin_try(self):
                self._tries += 1
-               self._current_task = asyncio.ensure_future(self._func(), 
loop=self._loop)
+               self._current_task = self._func()
                self._current_task.add_done_callback(self._try_done)
                if self._try_timeout is not None:
                        self._try_timeout_handle = self._loop.call_later(