76 |
|
""" |
77 |
|
Return scheduler-specific parameters |
78 |
|
""" |
79 |
+ |
req = '' |
80 |
+ |
if self.EDG_addJdlParam: |
81 |
+ |
if self.EDG_addJdlParam[-1] == '': |
82 |
+ |
self.EDG_addJdlParam = self.EDG_addJdlParam[:-1] |
83 |
+ |
for p in self.EDG_addJdlParam: |
84 |
+ |
req += p.strip()+';\n' |
85 |
|
|
86 |
< |
index = int(common._db.nJobs()) - 1 |
81 |
< |
schedParam = '' |
82 |
< |
|
83 |
< |
for i in range(index): |
84 |
< |
pass |
85 |
< |
|
86 |
< |
return schedParam |
86 |
> |
return req |
87 |
|
|
88 |
|
|
89 |
|
def realSchedParams(self, cfg_params): |
175 |
|
""" |
176 |
|
|
177 |
|
return txt |
178 |
+ |
|
179 |
+ |
|
180 |
+ |
def sched_fix_parameter(self): |
181 |
+ |
""" |
182 |
+ |
Returns string with requirements and scheduler-specific parameters |
183 |
+ |
""" |
184 |
+ |
|
185 |
+ |
if self.EDG_requirements: |
186 |
+ |
req = self.EDG_requirements |
187 |
+ |
taskReq = {'commonRequirements':req} |
188 |
+ |
common._db.updateTask_(taskReq) |