exception handling for schedds

kpedro88 · Sep 30, 2017 · 2c7135a · 2c7135a
1 parent b39865d
commit 2c7135a
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/python/jobSubmitter.py b/python/jobSubmitter.py
@@ -298,10 +298,13 @@ def findRunning(self):
             else:
                 coll = htcondor.Collector(collector)
             for sch in parser_dict["schedds"][cname].split(','):
-                scheddAd = coll.locate(htcondor.DaemonTypes.Schedd, sch)
-                schedd = htcondor.Schedd(scheddAd)
-                for result in schedd.xquery(constraint,["Out"]):
-                    runSet.add(self.runningToJobName(result["Out"]))
+                try:
+                    scheddAd = coll.locate(htcondor.DaemonTypes.Schedd, sch)
+                    schedd = htcondor.Schedd(scheddAd)
+                    for result in schedd.xquery(constraint,["Out"]):
+                        runSet.add(self.runningToJobName(result["Out"]))
+                except:
+                    print "Warning: could not locate schedd "+sch
 
         return runSet