diff options
| author |   Zac Medico <zmedico@gentoo.org> | 2018-04-22 09:19:27 -0700 |
|---|---|---|
| committer | Zac Medico <zmedico@gentoo.org> | 2018-04-22 09:24:37 -0700 |
| commit | a6e9c7cf429741015e26b923c8036416cc6bff7d (patch) | |
| tree | 7e038a2a42670cd954ebbb324aaa7049373549a0 | |
| parent | BinpkgFetcher: use async lock (bug 614110) (diff) | |
| download | portage-a6e9c7cf.tar.gz portage-a6e9c7cf.tar.bz2 portage-a6e9c7cf.zip | |
test_iter_completed: fix SleepProcess._future_done cancel race
Fixes: a9e8ebaa6979 ("Add async_iter_completed for asyncio migration (bug 591760)")
| -rw-r--r-- | pym/portage/tests/util/futures/test_iter_completed.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/pym/portage/tests/util/futures/test_iter_completed.py b/pym/portage/tests/util/futures/test_iter_completed.py index 1344523c6..b07146ed3 100644 --- a/pym/portage/tests/util/futures/test_iter_completed.py +++ b/pym/portage/tests/util/futures/test_iter_completed.py @@ -19,7 +19,8 @@ class SleepProcess(ForkProcess): ForkProcess._start(self) def _future_done(self, task): - self.future.set_result(self.seconds) + if not self.future.cancelled(): + self.future.set_result(self.seconds) def _run(self): time.sleep(self.seconds) |