##// END OF EJS Templates
schain-jc
RSS
GUI: minor changes
Miguel Valdez -
r687:a4cc28b3c350
parent child
Show More
Show file before | Show file after | Hide comments
@@ -5,6 +5,7 Created on September , 2012
5 5
6 6 import sys
7 7 import ast
8 import datetime
8 9 import traceback
9 10 import schainpy
10 11 import schainpy.admin
@@ -685,7 +686,7 class ReadUnitConf(ProcUnitConf):
685 686 self.name = name
686 687 self.datatype = datatype
687 688
688 self.path = path
689 self.path = os.path.abspath(path)
689 690 self.startDate = startDate
690 691 self.endDate = endDate
691 692 self.startTime = startTime
@@ -723,6 +724,13 class ReadUnitConf(ProcUnitConf):
723 724 self.parentId = parentId
724 725
725 726 self.updateRunOperation(**kwargs)
727
728 def removeOperations(self):
729
730 for obj in self.opConfObjList:
731 del obj
732
733 self.opConfObjList = []
726 734
727 735 def addRunOperation(self, **kwargs):
728 736
@@ -862,9 +870,12 class Project():
862 870 self.name = name
863 871 self.description = description
864 872
865 def addReadUnit(self, datatype=None, name=None, **kwargs):
873 def addReadUnit(self, id=None, datatype=None, name=None, **kwargs):
866 874
867 idReadUnit = self.__getNewId()
875 if id is None:
876 idReadUnit = self.__getNewId()
877 else:
878 idReadUnit = str(id)
868 879
869 880 readUnitConfObj = ReadUnitConf()
870 881 readUnitConfObj.setup(idReadUnit, name, datatype, parentId=self.id, **kwargs)
@@ -939,30 +950,36 class Project():
939 950
940 951 def writeXml(self, filename):
941 952
942 if not os.access(os.path.dirname(filename), os.W_OK):
953 abs_file = os.path.abspath(filename)
954
955 if not os.access(os.path.dirname(abs_file), os.W_OK):
956 print "No write permission on %s" %os.path.dirname(abs_file)
943 957 return 0
944 958
945 if os.path.isfile(filename) and not(os.access(filename, os.W_OK)):
959 if os.path.isfile(abs_file) and not(os.access(abs_file, os.W_OK)):
960 print "File %s already exists and it could not be overwriten" %abs_file
946 961 return 0
947 962
948 963 self.makeXml()
949 964
950 ElementTree(self.projectElement).write(filename, method='xml')
965 ElementTree(self.projectElement).write(abs_file, method='xml')
951 966
952 self.filename = filename
967 self.filename = abs_file
953 968
954 969 return 1
955 970
956 971 def readXml(self, filename):
957 972
958 if not os.path.isfile(filename):
959 print "%s does not exist" %filename
973 abs_file = os.path.abspath(filename)
974
975 if not os.path.isfile(abs_file):
976 print "%s does not exist" %abs_file
960 977 return 0
961 978
962 979 self.projectElement = None
963 980 self.procUnitConfObjDict = {}
964 981
965 self.projectElement = ElementTree().parse(filename)
982 self.projectElement = ElementTree().parse(abs_file)
966 983
967 984 self.project = self.projectElement.tag
968 985
@@ -1030,6 +1047,42 class Project():
1030 1047
1031 1048 self.__connect(puObjIN, thisPUObj)
1032 1049
1050 def __handleError(self, procUnitConfObj):
1051
1052 import socket
1053
1054 err = traceback.format_exception(sys.exc_info()[0],
1055 sys.exc_info()[1],
1056 sys.exc_info()[2])
1057
1058 subject = "SChain v%s: Error running %s\n" %(schainpy.__version__, procUnitConfObj.name)
1059
1060 subtitle = "%s: %s\n" %(procUnitConfObj.getElementName() ,procUnitConfObj.name)
1061 subtitle += "Hostname: %s\n" %socket.gethostbyname(socket.gethostname())
1062 subtitle += "Working directory: %s\n" %os.path.abspath("./")
1063 subtitle += "Configuration file: %s\n" %self.filename
1064 subtitle += "Time: %s\n" %str(datetime.datetime.now())
1065
1066 readUnitConfObj = self.getReadUnitObj()
1067 if readUnitConfObj:
1068 subtitle += "\nInput parameters:\n"
1069 subtitle += "[Data path = %s]\n" %readUnitConfObj.path
1070 subtitle += "[Data type = %s]\n" %readUnitConfObj.datatype
1071 subtitle += "[Start date = %s]\n" %readUnitConfObj.startDate
1072 subtitle += "[End date = %s]\n" %readUnitConfObj.endDate
1073 subtitle += "[Start time = %s]\n" %readUnitConfObj.startTime
1074 subtitle += "[End time = %s]\n" %readUnitConfObj.endTime
1075
1076 message = "".join(err)
1077
1078 sys.stderr.write(message)
1079
1080 adminObj = schainpy.admin.SchainNotify()
1081 adminObj.sendAlert(message=message,
1082 subject=subject,
1083 subtitle=subtitle,
1084 filename=self.filename)
1085
1033 1086 def isPaused(self):
1034 1087 return 0
1035 1088
@@ -1084,45 +1137,17 class Project():
1084 1137 try:
1085 1138 sts = procUnitConfObj.run()
1086 1139 is_ok = is_ok or sts
1140 except ValueError, e:
1141 print "***** Error occurred in %s *****" %(procUnitConfObj.name)
1142 sleep(0.5)
1143 print e
1144 is_ok = False
1145 break
1087 1146 except:
1088 1147 print "***** Error occurred in %s *****" %(procUnitConfObj.name)
1089
1090 1148 sleep(0.5)
1091
1092 err = traceback.format_exception(sys.exc_info()[0],
1093 sys.exc_info()[1],
1094 sys.exc_info()[2])
1095
1096 import socket
1097
1098 subject = "SChain v%s: Error running %s\n" %(schainpy.__version__, procUnitConfObj.name)
1099
1100 subtitle = "%s: %s\n" %(procUnitConfObj.getElementName() ,procUnitConfObj.name)
1101 subtitle += "Hostname: %s\n" %socket.gethostbyname(socket.gethostname())
1102 subtitle += "Working directory: %s\n" %os.path.abspath("./")
1103 subtitle += "Configuration file: %s\n" %self.filename
1104
1105 readUnitConfObj = self.getReadUnitObj()
1106 if readUnitConfObj:
1107 subtitle += "Data path: %s\n" %readUnitConfObj.path
1108 subtitle += "Data type: %s\n" %readUnitConfObj.datatype
1109 subtitle += "Start date: %s\n" %readUnitConfObj.startDate
1110 subtitle += "End date: %s\n" %readUnitConfObj.endDate
1111 subtitle += "Start time: %s\n" %readUnitConfObj.startTime
1112 subtitle += "End time: %s\n" %readUnitConfObj.endTime
1113
1114 message = "".join(err)
1115
1116 sys.stderr.write(message)
1117
1118 adminObj = schainpy.admin.SchainNotify()
1119 adminObj.sendAlert(message=message,
1120 subject=subject,
1121 subtitle=subtitle,
1122 filename=self.filename)
1123
1149 self.__handleError(procUnitConfObj)
1124 1150 is_ok = False
1125
1126 1151 break
1127 1152
1128 1153 #If every process unit finished so end process
@@ -1142,8 +1167,11 class Project():
1142 1167
1143 1168 def start(self, filename):
1144 1169
1145 self.writeXml(filename)
1146 self.readXml(filename)
1170 if not self.writeXml(filename):
1171 return
1172
1173 if not self.readXml(filename):
1174 return
1147 1175
1148 1176 self.createObjects()
1149 1177 self.connectObjects()
Show file before | Show file after | Hide comments
@@ -4130,9 +4130,7 class BasicWindow(QMainWindow, Ui_BasicWindow):
4130 4130
4131 4131 return projectObjView
4132 4132
4133 def createReadUnitView(self, projectObjView):
4134
4135 # project_name, description, datatype, data_path, startDate, endDate, startTime, endTime, online, delay, walk, set = self.getParmsFromProjectWindow()
4133 def createReadUnitView(self, projectObjView, idReadUnit=None):
4136 4134
4137 4135 projectParms = self.__getParmsFromProjectWindow()
4138 4136
@@ -4140,7 +4138,8 class BasicWindow(QMainWindow, Ui_BasicWindow):
4140 4138 return None
4141 4139
4142 4140 if projectParms.datatype in ("Voltage", "Spectra", "Fits"):
4143 readUnitConfObj = projectObjView.addReadUnit(datatype=projectParms.datatype,
4141 readUnitConfObj = projectObjView.addReadUnit(id=idReadUnit,
4142 datatype=projectParms.datatype,
4144 4143 path=projectParms.dpath,
4145 4144 startDate=projectParms.startDate,
4146 4145 endDate=projectParms.endDate,
@@ -4162,7 +4161,8 class BasicWindow(QMainWindow, Ui_BasicWindow):
4162 4161 readUnitConfObj.addOperation(name="printInfo")
4163 4162
4164 4163 if projectParms.datatype == "USRP":
4165 readUnitConfObj = projectObjView.addReadUnit(datatype=projectParms.datatype,
4164 readUnitConfObj = projectObjView.addReadUnit(id=idReadUnit,
4165 datatype=projectParms.datatype,
4166 4166 path=projectParms.dpath,
4167 4167 startDate=projectParms.startDate,
4168 4168 endDate=projectParms.endDate,
@@ -4179,50 +4179,10 class BasicWindow(QMainWindow, Ui_BasicWindow):
4179 4179
4180 4180 def updateReadUnitView(self, projectObjView, idReadUnit):
4181 4181
4182 # project_name, description, datatype, data_path, startDate, endDate, startTime, endTime, online, delay, walk , set = self.getParmsFromProjectWindow()
4183
4184 readUnitConfObj = projectObjView.getProcUnitObj(idReadUnit)
4185
4186 projectParms = self.__getParmsFromProjectWindow()
4182 projectObjView.removeProcUnit(idReadUnit)
4187 4183
4188 if not projectParms.isValid():
4189 return None
4184 readUnitConfObj = self.createReadUnitView(projectObjView, idReadUnit)
4190 4185
4191 if projectParms.datatype in ["Voltage", "Spectra", "Fits"]:
4192 readUnitConfObj.update(datatype=projectParms.datatype,
4193 path=projectParms.dpath,
4194 startDate=projectParms.startDate,
4195 endDate=projectParms.endDate,
4196 startTime=projectParms.startTime,
4197 endTime=projectParms.endTime,
4198 online=projectParms.online,
4199 walk=projectParms.walk
4200 )
4201 if projectParms.set:
4202 readUnitConfObj.addParameter(name="set", value=projectParms.set, format="int")
4203
4204 if projectParms.delay:
4205 readUnitConfObj.addParameter(name="delay", value=projectParms.delay, format="int")
4206
4207 if projectParms.expLabel:
4208 readUnitConfObj.addParameter(name="expLabel", value=projectParms.expLabel)
4209
4210 readUnitConfObj.addOperation(name="printInfo")
4211
4212 if projectParms.datatype == "USRP":
4213 readUnitConfObj.update(datatype=projectParms.datatype,
4214 path=projectParms.dpath,
4215 startDate=projectParms.startDate,
4216 endDate=projectParms.endDate,
4217 startTime=projectParms.startTime,
4218 endTime=projectParms.endTime,
4219 online=projectParms.online,
4220 ippKm=projectParms.ippKm
4221 )
4222
4223 if projectParms.delay:
4224 readUnitConfObj.addParameter(name="delay", value=projectParms.delay, format="int")
4225
4226 4186 return readUnitConfObj
4227 4187
4228 4188 def createProcUnitView(self, projectObjView, datatype, inputId):
General Comments 0
You need to be logged in to leave comments. Login now