| 201 |
|
# get the data and fill the file content |
| 202 |
|
statusMsg = self.asSession.getTaskStatus(statusFamilyType, blTaskName) |
| 203 |
|
if 'Error:' in statusMsg[:6] or len(statusMsg)==0: |
| 204 |
< |
raise CrabException('Error occurred while retrieving task %s status from server %s'%(self.crab_task_name, self.serverName) ) |
| 205 |
< |
return |
| 204 |
> |
if statusFamilyType != 'isServerDrained': |
| 205 |
> |
raise CrabException('Error in retrieving task %s status from server %s'%(self.crab_task_name, self.serverName) ) |
| 206 |
> |
else: |
| 207 |
> |
statusFile = None |
| 208 |
> |
statusMMsg = "" |
| 209 |
|
|
| 210 |
|
if statusFile is not None: |
| 211 |
|
f = open(statusFile, 'w') |
