10 |
|
nj_list = [] |
11 |
|
|
12 |
|
nj_list = self.checkAlowedJob(jobs,nj_list) |
13 |
+ |
|
14 |
+ |
manageNewRunJobs(nj_list) |
15 |
|
|
16 |
|
common.logger.message('Jobs '+str(nj_list)+' will be resubmitted') |
17 |
|
Submitter.__init__(self, cfg_params, nj_list, 'range') |
21 |
|
def checkAlowedJob(self,jobs,nj_list): |
22 |
|
listRunField=[] |
23 |
|
run_jobToSave = {'status' :'C', \ |
24 |
< |
'statusScheduler' : 'Created', \ |
23 |
< |
'closed' : 'N', \ |
24 |
< |
'applicationReturnCode' : '',\ |
25 |
< |
'wrapperReturnCode' : '' } |
24 |
> |
'statusScheduler' : 'Created'} |
25 |
|
|
26 |
|
task=common._db.getTask(jobs) |
27 |
|
for job in task.jobs: |
45 |
|
return nj_list |
46 |
|
|
47 |
|
if UseServer==1: SubmitterServer.__init__(self, cfg_params, nj_list, 'range') |
48 |
+ |
|
49 |
+ |
def manageNewRunJobs(self,nj_list): |
50 |
+ |
""" |
51 |
+ |
Get new running instances |
52 |
+ |
""" |
53 |
+ |
common._db.newRunJobs(nj_list) |
54 |
+ |
return |