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