pypet/storageservice.py
def _trj_prepare_merge(self, traj, changed_parameters, old_length):
        """Prepares a trajectory for merging.

        This function will already store extended parameters.

        :param traj: Target of merge
        :param changed_parameters: List of extended parameters (i.e. their names).

        """

        if not traj._stored:
            traj.f_store()

        # Update meta information
        infotable = getattr(self._overview_group, 'info')
        insert_dict = self._all_extract_insert_dict(traj, infotable.colnames)
        self._all_add_or_modify_row(traj.v_name, insert_dict, infotable, index=0,
                                    flags=(HDF5StorageService.MODIFY_ROW,))

        # Store extended parameters
        for param_name in changed_parameters:
            param = traj.f_get(param_name)

            try:
                self._all_delete_parameter_or_result_or_group(param)
            except pt.NoSuchNodeError:
                pass  # We are fine and the node did not exist in the first place

        # Increase the run table by the number of new runs
        run_table = getattr(self._overview_group, 'runs')
        actual_rows = run_table.nrows
        self._trj_fill_run_table(traj, actual_rows, len(traj))

        # Extract parameter summary and if necessary create new explored parameter tables
        # in the result groups
        for idx in range(old_length, len(traj)):
            run_name = traj.f_idx_to_run(idx)
            run_info = traj.f_get_run_information(run_name)
            run_info['name'] = run_name

            traj._set_explored_parameters_to_idx(idx)

            run_summary = self._srn_summarize_explored_parameters(list(
                                                            traj._explored_parameters.values()))

            run_info['parameter_summary'] = run_summary

            self._all_add_or_modify_row(run_name, run_info, run_table, index=idx,
                                        flags=(HDF5StorageService.MODIFY_ROW,))

        traj.f_restore_default()
def _trj_prepare_merge(self, traj, changed_parameters, old_length):
        if not traj._stored:
            traj.f_store()

        # Update meta information
        infotable = getattr(self._overview_group, 'info')
        insert_dict = self._all_extract_insert_dict(traj, infotable.colnames)
        self._all_add_or_modify_row(traj.v_name, insert_dict, infotable, index=0,
                                    flags=(HDF5StorageService.MODIFY_ROW,))

        # Store extended parameters
        for param_name in changed_parameters:
            param = traj.f_get(param_name)

            try:
                self._all_delete_parameter_or_result_or_group(param)
            except pt.NoSuchNodeError:
                pass  # We are fine and the node did not exist in the first place

        # Increase the run table by the number of new runs
        run_table = getattr(self._overview_group, 'runs')
        actual_rows = run_table.nrows
        self._trj_fill_run_table(traj, actual_rows, len(traj))

        # Extract parameter summary and if necessary create new explored parameter tables
        # in the result groups
        for idx in range(old_length, len(traj)):
            run_name = traj.f_idx_to_run(idx)
            run_info = traj.f_get_run_information(run_name)
            run_info['name'] = run_name

            traj._set_explored_parameters_to_idx(idx)

            run_summary = self._srn_summarize_explored_parameters(list(
                                                            traj._explored_parameters.values()))

            run_info['parameter_summary'] = run_summary

            self._all_add_or_modify_row(run_name, run_info, run_table, index=idx,
                                        flags=(HDF5StorageService.MODIFY_ROW,))

        traj.f_restore_default()
def _trj_prepare_merge ( self , traj , changed_parameters , old_length ) : if not traj . _stored : traj . f_store ( ) # Update meta information infotable = getattr ( self . _overview_group , 'info' ) insert_dict = self . _all_extract_insert_dict ( traj , infotable . colnames ) self . _all_add_or_modify_row ( traj . v_name , insert_dict , infotable , index = 0 , flags = ( HDF5StorageService . MODIFY_ROW , ) ) # Store extended parameters for param_name in changed_parameters : param = traj . f_get ( param_name ) try : self . _all_delete_parameter_or_result_or_group ( param ) except pt . NoSuchNodeError : pass # We are fine and the node did not exist in the first place # Increase the run table by the number of new runs run_table = getattr ( self . _overview_group , 'runs' ) actual_rows = run_table . nrows self . _trj_fill_run_table ( traj , actual_rows , len ( traj ) ) # Extract parameter summary and if necessary create new explored parameter tables # in the result groups for idx in range ( old_length , len ( traj ) ) : run_name = traj . f_idx_to_run ( idx ) run_info = traj . f_get_run_information ( run_name ) run_info [ 'name' ] = run_name traj . _set_explored_parameters_to_idx ( idx ) run_summary = self . _srn_summarize_explored_parameters ( list ( traj . _explored_parameters . values ( ) ) ) run_info [ 'parameter_summary' ] = run_summary self . _all_add_or_modify_row ( run_name , run_info , run_table , index = idx , flags = ( HDF5StorageService . MODIFY_ROW , ) ) traj . f_restore_default ( )
Prepares a trajectory for merging.

        This function will already store extended parameters.

        :param traj: Target of merge
        :param changed_parameters: List of extended parameters (i.e. their names).
Prepares a trajectory for merging .