| 97 |
|
|
| 98 |
|
logMsg = '' |
| 99 |
|
if ret == 10: |
| 100 |
< |
# overlaod |
| 101 |
< |
logMsg = 'Error The server %s refused to accept the task %s because it is overloaded\n'%(self.serverName, self.crab_task_name) |
| 102 |
< |
logMsg += '\t For Further infos please contact the server Admin: %s'%self.server_admin |
| 100 |
> |
# overlaod |
| 101 |
> |
logMsg = 'Error The server %s refused to accept the task %s because it is overloaded\n'%(self.serverName, self.crab_task_name) |
| 102 |
> |
logMsg += '\t For Further infos please contact the server Admin: %s'%self.server_admin |
| 103 |
|
elif ret == 14: |
| 104 |
< |
# Draining |
| 105 |
< |
logMsg = 'Error The server %s refused to accept the task %s because it is Draining out\n'%(self.serverName, self.crab_task_name) |
| 106 |
< |
logMsg += '\t remaining jobs due to scheduled maintainence\n' |
| 107 |
< |
logMsg += '\t For Further infos please contact the server Admin: %s'%self.server_admin |
| 104 |
> |
# Draining |
| 105 |
> |
logMsg = 'Error The server %s refused to accept the task %s because it is Draining out\n'%(self.serverName, self.crab_task_name) |
| 106 |
> |
logMsg += '\t remaining jobs due to scheduled maintainence\n' |
| 107 |
> |
logMsg += '\t For Further infos please contact the server Admin: %s'%self.server_admin |
| 108 |
|
elif ret == 101: |
| 109 |
< |
# overlaod |
| 110 |
< |
logMsg = 'Error The server %s refused the submission %s because you asked a too large task. Please submit by range'%(self.serverName, self.crab_task_name) |
| 109 |
> |
# overlaod |
| 110 |
> |
logMsg = 'Error The server %s refused the submission %s because you asked a too large task. Please submit by range'%(self.serverName, self.crab_task_name) |
| 111 |
|
elif ret == 11: |
| 112 |
< |
# failed to push message in DB |
| 113 |
< |
logMsg = 'Backend unable to release messages to trigger the computation of task %s'%self.crab_task_name |
| 112 |
> |
# failed to push message in DB |
| 113 |
> |
logMsg = 'Backend unable to release messages to trigger the computation of task %s'%self.crab_task_name |
| 114 |
|
elif ret == 12: |
| 115 |
< |
# failed SOAP communication |
| 116 |
< |
logMsg = 'Error The server %s refused to accept the task %s. It could be under maintainance. \n'%(self.serverName, self.crab_task_name) |
| 117 |
< |
logMsg += '\t For Further infos please contact the server Admin: %s'%self.server_admin |
| 115 |
> |
# failed SOAP communication |
| 116 |
> |
logMsg = 'Error The server %s refused to accept the task %s. It could be under maintainance. \n'%(self.serverName, self.crab_task_name) |
| 117 |
> |
logMsg += '\t For Further infos please contact the server Admin: %s'%self.server_admin |
| 118 |
|
elif ret == 20: |
| 119 |
< |
# failed to push message in PA |
| 120 |
< |
logMsg = 'Backend unable to release messages to trigger the computation of task %s'%self.crab_task_name |
| 119 |
> |
# failed to push message in PA |
| 120 |
> |
logMsg = 'Backend unable to release messages to trigger the computation of task %s'%self.crab_task_name |
| 121 |
|
elif ret == 22: |
| 122 |
< |
# failed SOAP communication |
| 123 |
< |
logMsg = 'Error during SOAP communication with server %s'%self.serverName |
| 122 |
> |
# failed SOAP communication |
| 123 |
> |
logMsg = 'Error during SOAP communication with server %s'%self.serverName |
| 124 |
|
elif ret == 33: |
| 125 |
< |
# uncompatible client version |
| 126 |
< |
logMsg = 'Error You are using a wrong client version for server: %s\n'%self.serverName |
| 127 |
< |
logMsg += '\t For further informations about "Servers available for users" please check here:\n \t%s '%self.ServerTwiki |
| 125 |
> |
# uncompatible client version |
| 126 |
> |
logMsg = 'Error You are using a wrong client version for server: %s\n'%self.serverName |
| 127 |
> |
logMsg += '\t For further informations about "Servers available for users" please check here:\n \t%s '%self.ServerTwiki |
| 128 |
|
else: |
| 129 |
< |
logMsg = 'Unexpected return code from server %s: %d'%(self.serverName, ret) |
| 129 |
> |
logMsg = 'Unexpected return code from server %s: %d'%(self.serverName, ret) |
| 130 |
|
|
| 131 |
|
# print loggings |
| 132 |
|
if logMsg != '': |
| 133 |
+ |
# reset server choice |
| 134 |
+ |
opsToBeSaved={'serverName' : '' } |
| 135 |
+ |
common._db.updateTask_(opsToBeSaved) |
| 136 |
|
raise CrabException(logMsg) |
| 137 |
|
return ret |
| 138 |
|
|
