b9ffc2cc041e95367a84059e57f8508c479739cc,tgen/parallel_percrank_train.py,ParallelTrainingPercRank,train,#ParallelTrainingPercRank#Any#Any#Any#,43

Before Change

                    for conn, req_portion, req in list(self.pending_requests):
                        if req.ready:
                            if req.error:
                                raise Exception("Request computed with error: IT %d PORTION %d, WORKER %s:%d" %
                                                (iter_no, req_portion, conn.host, conn.port))
                            results[req_portion] = req.value
                            self.pending_requests.remove(conn, req_portion, req)
                            self.free_services.append(conn)
                    // check for free services and assign new computation

After Change

                    // check if some of the pending computations have finished
                    for sc, req_portion, req in list(self.pending_requests):
                        if req.ready:
                            log_info("Retrieved finished request %d / %d" % (iter_no, req_portion))
                            if req.error:
                                log_info("Error found on request: IT %d PORTION %d, WORKER %s:%d" %
                                         (iter_no, req_portion, sc.host, sc.port))
                            results[req_portion] = req.value

Instances