previous_runs.py 文件源码

def load_previous_runs(self):
        if not os.path.isfile(self.prev_runs_file_):
            self.found_matching_run = False
            return

        with open(self.prev_runs_file_, 'r') as file:
            self.all_prev_runs_ = yaml.load(file)
            for run in self.all_prev_runs_:
                self.max_data_version_ = max(self.max_data_version_, run['input_data_version'])
                if run['input_data_hash'] == self.data_.df_hash:
                    self.max_config_version_ = max(self.max_config_version_, run['config_version'])
                    if run['config_hash'] == self.config_hash_:
                        if self.found_matching_run:
                            raise Exception('Duplicate previous run entries found.')
                        self.found_matching_run = True
                        self.run_ = run
                        self.data_folder_ = self.get_versioned_folder(run['input_data_version'],
                                                                      run['config_version'])

        if self.found_matching_run is None:
            self.found_matching_run = False