107 |
|
|
108 |
|
return |
109 |
|
|
110 |
< |
def createJobs_(self, jobsL): |
110 |
> |
def createJobs_(self, jobsL, isNew=True): |
111 |
|
""" |
112 |
|
Fill crab DB with the jobs filed |
113 |
|
""" |
116 |
|
jobs = [] |
117 |
|
for id in jobsL: |
118 |
|
parameters = {} |
119 |
< |
parameters['jobId'] = str(id) |
119 |
> |
parameters['jobId'] = int(id) |
120 |
> |
parameters['taskId'] = 1 |
121 |
|
parameters['name'] = task['name'] + '_' + 'job' + str(id) |
122 |
|
job = Job(parameters) |
123 |
|
jobs.append(job) |
124 |
|
common.bossSession.getRunningInstance(job) |
125 |
|
job.runningJob['status'] = 'C' |
126 |
< |
task.addJobs(jobs) |
126 |
> |
## added to support second step creation |
127 |
> |
## maybe it is not needed. TO CLARIFY |
128 |
> |
if isNew: |
129 |
> |
task.addJobs(jobs) |
130 |
> |
else: |
131 |
> |
task.appendJobs(jobs) |
132 |
|
try: |
133 |
|
common.bossSession.updateDB( task ) |
134 |
|
except Exception, e : |