pypet/storageservice.py
def _trj_fill_run_table(self, traj, start, stop):
        """Fills the `run` overview table with information.

        Will also update new information.

        """

        def _make_row(info_dict):
            row = (info_dict['idx'],
                   info_dict['name'],
                   info_dict['time'],
                   info_dict['timestamp'],
                   info_dict['finish_timestamp'],
                   info_dict['runtime'],
                   info_dict['parameter_summary'],
                   info_dict['short_environment_hexsha'],
                   info_dict['completed'])
            return row

        runtable = getattr(self._overview_group, 'runs')

        rows = []
        updated_run_information = traj._updated_run_information
        for idx in range(start, stop):
            info_dict = traj._run_information[traj._single_run_ids[idx]]
            rows.append(_make_row(info_dict))
            updated_run_information.discard(idx)

        if rows:
            runtable.append(rows)
            runtable.flush()

        # Store all runs that are updated and that have not been stored yet
        rows = []
        indices = []
        for idx in updated_run_information:
            info_dict = traj.f_get_run_information(idx, copy=False)
            rows.append(_make_row(info_dict))
            indices.append(idx)

        if rows:
            runtable.modify_coordinates(indices, rows)

        traj._updated_run_information = set()
def _trj_fill_run_table(self, traj, start, stop):
        """Fills the `run` overview table with information.

        Will also update new information.

        """

        def _make_row(info_dict):
            row = (info_dict['idx'],
                   info_dict['name'],
                   info_dict['time'],
                   info_dict['timestamp'],
                   info_dict['finish_timestamp'],
                   info_dict['runtime'],
                   info_dict['parameter_summary'],
                   info_dict['short_environment_hexsha'],
                   info_dict['completed'])
            return row

        runtable = getattr(self._overview_group, 'runs')

        rows = []
        updated_run_information = traj._updated_run_information
        for idx in range(start, stop):
            info_dict = traj._run_information[traj._single_run_ids[idx]]
            rows.append(_make_row(info_dict))
            updated_run_information.discard(idx)

        if rows:
            runtable.append(rows)
            runtable.flush()

        # Store all runs that are updated and that have not been stored yet
        rows = []
        indices = []
        for idx in updated_run_information:
            info_dict = traj.f_get_run_information(idx, copy=False)
            rows.append(_make_row(info_dict))
            indices.append(idx)

        if rows:
            runtable.modify_coordinates(indices, rows)

        traj._updated_run_information = set()
def _trj_fill_run_table ( self , traj , start , stop ) : def _make_row ( info_dict ) : row = ( info_dict [ 'idx' ] , info_dict [ 'name' ] , info_dict [ 'time' ] , info_dict [ 'timestamp' ] , info_dict [ 'finish_timestamp' ] , info_dict [ 'runtime' ] , info_dict [ 'parameter_summary' ] , info_dict [ 'short_environment_hexsha' ] , info_dict [ 'completed' ] ) return row runtable = getattr ( self . _overview_group , 'runs' ) rows = [ ] updated_run_information = traj . _updated_run_information for idx in range ( start , stop ) : info_dict = traj . _run_information [ traj . _single_run_ids [ idx ] ] rows . append ( _make_row ( info_dict ) ) updated_run_information . discard ( idx ) if rows : runtable . append ( rows ) runtable . flush ( ) # Store all runs that are updated and that have not been stored yet rows = [ ] indices = [ ] for idx in updated_run_information : info_dict = traj . f_get_run_information ( idx , copy = False ) rows . append ( _make_row ( info_dict ) ) indices . append ( idx ) if rows : runtable . modify_coordinates ( indices , rows ) traj . _updated_run_information = set ( )
Fills the `run` overview table with information.

        Will also update new information.
Fills the run overview table with information .