def killBatchJobs(self, jobIDs):
        """Kills jobs by ID."""
        log.debug('Killing jobs: {}'.format(jobIDs))
        for jobID in jobIDs:
            if jobID in self.runningJobs:
                info = self.runningJobs[jobID]
                info.killIntended = True
                if info.popen != None:
                    os.kill(info.popen.pid, 9)
                else:
                    # No popen if running in forkless mode currently 
                    assert self.debugWorker
                    log.critical("Can't kill job: %s in debug mode" % jobID)
                while jobID in self.runningJobs:
                    pass
def killBatchJobs ( self , jobIDs ) : log . debug ( 'Killing jobs: {}' . format ( jobIDs ) ) for jobID in jobIDs : if jobID in self . runningJobs : info = self . runningJobs [ jobID ] info . killIntended = True if info . popen != None : os . kill ( info . popen . pid , 9 ) else : assert self . debugWorker log . critical ( "Can't kill job: %s in debug mode" % jobID ) while jobID in self . runningJobs : pass
Kills jobs by ID.