From 470275d663798ee373168a58353087709ebecf46 Mon Sep 17 00:00:00 2001
From: Joseph Weston <joseph.weston08@gmail.com>
Date: Fri, 21 Jul 2017 14:00:41 +0200
Subject: [PATCH] fix bug when already-completed futures are added
---
learner1D.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/learner1D.py b/learner1D.py
index d09e0507..63466aae 100644
--- a/learner1D.py
+++ b/learner1D.py
@@ -199,7 +199,8 @@ class Learner1D(object):
async def any_complete(futures):
total = tornado.concurrent.Future()
for f in futures:
- f.add_done_callback(total.set_result)
+ f.add_done_callback(lambda f: total.set_result(None)
+ if not total.done() else None)
await total
return [f for f in futures if f.done()]
--
GitLab