@@ -143,8 +143,10 @@ def _ask_and_tell_based_on_loss(self, n):
143143 total_points = [l .npoints + len (l .pending_points ) for l in self .learners ]
144144 for _ in range (n ):
145145 losses = self ._losses (real = False )
146- priority = zip (losses , (- n for n in total_points ))
147- index = max (enumerate (priority ), key = itemgetter (1 ))[0 ]
146+ index , _ = max (
147+ enumerate (zip (losses , (- n for n in total_points ))),
148+ key = itemgetter (1 )
149+ )
148150 total_points [index ] += 1
149151
150152 # Take the points from the cache
@@ -153,6 +155,7 @@ def _ask_and_tell_based_on_loss(self, n):
153155 points , loss_improvements = self ._ask_cache [index ]
154156
155157 selected .append (((index , points [0 ]), loss_improvements [0 ]))
158+ self .tell_pending ((index , points [0 ]))
156159
157160 points , loss_improvements = map (list , zip (* selected ))
158161 return points , loss_improvements
@@ -170,6 +173,7 @@ def _ask_and_tell_based_on_npoints(self, n):
170173 total_points [index ] += 1
171174 n_left -= 1
172175 selected .append (((index , points [0 ]), loss_improvements [0 ]))
176+ self .tell_pending ((index , points [0 ]))
173177
174178 points , loss_improvements = map (list , zip (* selected ))
175179 return points , loss_improvements
0 commit comments