get_queued_jobs only checks normal queued jobs

jtriley · Jan 29, 2015 · d29aebc · d29aebc
1 parent 5358527
commit d29aebc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/starcluster/balancers/sge/__init__.py b/starcluster/balancers/sge/__init__.py
@@ -203,7 +203,7 @@ def get_queued_jobs(self):
         """
         queued = []
         for j in self.jobs:
-            if j['job_state'] == u'pending':
+            if j['job_state'] == u'pending' and j['state'] == u'qw':
                 queued.append(j)
         return queued