Merge pull request #148 from Microsoft/master

merge master

src/nni_manager/core/nniDataStore.ts

@@ -250,29 +250,26 @@ class NNIDataStore implements DataStore {
         return <TrialJobStatus>event;
     }
 
-    private mergeHyperParameters(hyperParamList: string[], newParamStr: string): string[] {
-        const mergedHyperParams: any[] = [];
-        let newParam: any;
+    private parseHyperParameter(hParamStr: string): any {
+        let hParam: any;
         try {
-            newParam = JSON.parse(newParamStr);
+            hParam = JSON.parse(hParamStr);
+
+            return hParam;
         } catch (err) {
-            this.log.error(`Hyper parameter needs to be in json format: ${newParamStr}`);
+            this.log.error(`Hyper parameter needs to be in json format: ${hParamStr}`);
 
-            return hyperParamList;
-        }
-        for (const hyperParamStr of hyperParamList) {
-            const hyperParam: any = JSON.parse(hyperParamStr);
-            mergedHyperParams.push(hyperParam);
+            return undefined;
         }
-        if (mergedHyperParams.filter((value: any) => value.parameter_index === newParam.parameter_index).length <= 0) {
-            mergedHyperParams.push(newParam);
-        }
-
-        return mergedHyperParams.map<string>((value: any) => { return JSON.stringify(value); });
     }
 
+    // tslint:disable-next-line:cyclomatic-complexity
     private getTrialJobsByReplayEvents(trialJobEvents: TrialJobEventRecord[]):  Map<string, TrialJobInfo> {
+        this.log.debug('getTrialJobsByReplayEvents begin');
+
         const map: Map<string, TrialJobInfo> = new Map();
+        const hParamIdMap: Map<string, Set<number>> = new Map();
+
         // assume data is stored by time ASC order
         for (const record of trialJobEvents) {
             let jobInfo: TrialJobInfo | undefined;
@@ -322,18 +319,31 @@ class NNIDataStore implements DataStore {
             }
             jobInfo.status = this.getJobStatusByLatestEvent(jobInfo.status, record.event);
             if (record.data !== undefined && record.data.trim().length > 0) {
+                const newHParam: any = this.parseHyperParameter(record.data);
+                if (newHParam !== undefined) {
                     if (jobInfo.hyperParameters !== undefined) {
-                    jobInfo.hyperParameters = this.mergeHyperParameters(jobInfo.hyperParameters, record.data);
+                        let hParamIds: Set<number> | undefined = hParamIdMap.get(jobInfo.id);
+                        if (hParamIds === undefined) {
+                            hParamIds = new Set();
+                        }
+                        if (!hParamIds.has(newHParam.parameter_index)) {
+                            jobInfo.hyperParameters.push(JSON.stringify(newHParam));
+                            hParamIds.add(newHParam.parameter_index);
+                            hParamIdMap.set(jobInfo.id, hParamIds);
+                        }
                     } else {
                         assert(false, 'jobInfo.hyperParameters is undefined');
                     }
                 }
+            }
             if (record.sequenceId !== undefined && jobInfo.sequenceId === undefined) {
                 jobInfo.sequenceId = record.sequenceId;
             }
             map.set(record.trialJobId, jobInfo);
         }
 
+        this.log.debug('getTrialJobsByReplayEvents done');
+
         return map;
     }
 }

src/sdk/pynni/nni/hyperband_advisor/hyperband_advisor.py

@@ -300,7 +300,7 @@ class Hyperband(MsgDispatcherBase):
     """
     def __init__(self, R, eta=3, optimize_mode='maximize'):
         """B = (s_max + 1)R"""
-        super()
+        super(Hyperband, self).__init__()
         self.R = R                        # pylint: disable=invalid-name
         self.eta = eta
         self.brackets = dict()            # dict of Bracket