LocalEngine.py 文件源码

def __init__(self):        
        self._pipelineName_by_jobId = {}
        self._cmdStr_by_jobId = {}
        self._resources_by_jobId = {}
        self._job_outdir_by_jobId = {}
        self._localStatus_by_jobId = {}
        self._running_processes_by_jobId = {}
        self._filehandles_by_jobId = {}
        try:
            self._user = getpass.getuser()
        except KeyError:
            self._user = "unknown"

        self._firehose_mode = self._user.startswith('cgaadm')

        (cpu_count, mem_gb) = self._get_host_resources()
        self._numcores = cpu_count
        self._totmem = mem_gb
        print ('Local host has ' + str(cpu_count) + ' cores and ' + str(mem_gb) + 'GB.')