Skip to content

Commit dde5e25

Browse files
committed
update groups args and groups line conflict
1 parent 00ce66b commit dde5e25

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

src/sge_run.py

+8-2
Original file line numberDiff line numberDiff line change
@@ -103,14 +103,20 @@ def group_jobs(self):
103103
self.throw('groups conflict in "%s" line number %d: "%s"' % (self.jfile,
104104
jb.linenum, jb.cmd0))
105105
elif n >= i and (n-i) % self.groups == 0:
106-
self._make_groups(wait_groups[n:n+self.groups])
106+
gs = []
107+
for j in wait_groups[n:n+self.groups]:
108+
if j.groups:
109+
break
110+
gs.append(j)
111+
self._make_groups(gs)
107112

108113
def _make_groups(self, jobs=None):
109114
if len(jobs) > 1:
110115
j_header = jobs[0]
111116
for j in jobs[1:]:
112117
j_header.rawstring += "\n" + j.rawstring
113-
self.jobs.remove(j)
118+
if j in self.jobs:
119+
self.jobs.remove(j)
114120
self.jobsgraph.delete_node_if_exists(j.jobname)
115121
j_header.raw2cmd()
116122
self.totaljobdict[j_header.jobname] = j_header

0 commit comments

Comments
 (0)