| @@ -1070,7 +1070,7 class Project(): | |||
|
|
1070 | 1070 | |
|
|
1071 | 1071 | self.__connect(puObjIN, thisPUObj) |
|
|
1072 | 1072 | |
|
|
1073 | def __handleError(self, procUnitConfObj): | |
|
|
1073 | def __handleError(self, procUnitConfObj, send_email=True): | |
|
|
1074 | 1074 | |
|
|
1075 | 1075 | import socket |
|
|
1076 | 1076 | |
| @@ -1078,6 +1078,13 class Project(): | |||
|
|
1078 | 1078 | sys.exc_info()[1], |
|
|
1079 | 1079 | sys.exc_info()[2]) |
|
|
1080 | 1080 | |
|
|
1081 | message = "".join(err) | |
|
|
1082 | ||
|
|
1083 | sys.stderr.write(message) | |
|
|
1084 | ||
|
|
1085 | if not send_email: | |
|
|
1086 | return | |
|
|
1087 | ||
|
|
1081 | 1088 | subject = "SChain v%s: Error running %s\n" %(schainpy.__version__, procUnitConfObj.name) |
|
|
1082 | 1089 | |
|
|
1083 | 1090 | subtitle = "%s: %s\n" %(procUnitConfObj.getElementName() ,procUnitConfObj.name) |
| @@ -1095,10 +1102,6 class Project(): | |||
|
|
1095 | 1102 | subtitle += "[End date = %s]\n" %readUnitConfObj.endDate |
|
|
1096 | 1103 | subtitle += "[Start time = %s]\n" %readUnitConfObj.startTime |
|
|
1097 | 1104 | subtitle += "[End time = %s]\n" %readUnitConfObj.endTime |
|
|
1098 | ||
|
|
1099 | message = "".join(err) | |
|
|
1100 | ||
|
|
1101 | sys.stderr.write(message) | |
|
|
1102 | 1105 | |
|
|
1103 | 1106 | adminObj = schainpy.admin.SchainNotify() |
|
|
1104 | 1107 | adminObj.sendAlert(message=message, |
| @@ -1179,7 +1182,7 class Project(): | |||
|
|
1179 | 1182 | except ValueError, e: |
|
|
1180 | 1183 | print "***** Error occurred in %s *****" %(procUnitConfObj.name) |
|
|
1181 | 1184 | sleep(0.5) |
|
|
1182 | print e | |
|
|
1185 | self.__handleError(procUnitConfObj, send_email=False) | |
|
|
1183 | 1186 | is_ok = False |
|
|
1184 | 1187 | break |
|
|
1185 | 1188 | except: |
General Comments 0
You need to be logged in to leave comments.
Login now