Source code for siriushla.as_ap_configdb.normconfigs.LoadingThread

import os
from epics import caget
from qtpy.QtCore import Signal, QThread
from qtpy.QtWidgets import QDialog




class LoadingThread(QThread):
    VACA_PREFIX = os.environ.get('VACA_PREFIX', default='')

    taskUpdated = Signal(int)
    taskFinished = Signal(int)

    def __init__(self, name, pv_list, parent=None):
        super(LoadingThread, self).__init__(parent)
        self.name = name
        self.pv_list = pv_list
        self.parent = parent



    def run(self):
        values = dict()
        for i, pvname in enumerate(self.pv_list):
            # current_pv = ':'.join(pvname['name'].split(':')[:2]) + ':Current-RB'
            force = caget(self.VACA_PREFIX + pvname["name"], timeout=0.3)  # readForce
            if force is None:
                force = -1
            values[pvname['name']] = force
            self.taskUpdated.emit(i + 1)

        self.parent._model.loadConfiguration(name=self.name, values=values)
        self.taskFinished.emit(QDialog.Accepted)