From 1cb8f51f8c892662510344e8ca4afdb8a74cd07c Mon Sep 17 00:00:00 2001 From: weisburd Date: Thu, 24 Jun 2010 23:44:10 +0000 Subject: [PATCH] Fixed -t arg git-svn-id: file:///humgen/gsa-scr1/gsa-engineering/svn_contents/trunk@3634 348d0f76-0448-11de-a6fe-93d51630548a --- python/genomicAnnotatorScripts/GenerateTranscriptToInfo.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/python/genomicAnnotatorScripts/GenerateTranscriptToInfo.py b/python/genomicAnnotatorScripts/GenerateTranscriptToInfo.py index a61eee475..e8a2cc61a 100755 --- a/python/genomicAnnotatorScripts/GenerateTranscriptToInfo.py +++ b/python/genomicAnnotatorScripts/GenerateTranscriptToInfo.py @@ -126,7 +126,7 @@ running_processes = [] def execute(command, stdout_filename=None): # Wait until a slot becomes open - while len( running_processes ) + 1 >= num_parallel_processes: + while len( running_processes ) >= num_parallel_processes: # Check if any have ended for process in running_processes: if process.poll() != None: @@ -142,6 +142,7 @@ def execute(command, stdout_filename=None): stdout = open(stdout_filename, "w+") + print("Executing: " + command) p = subprocess.Popen(shlex.split(command), stdout=stdout, stderr=subprocess.STDOUT) running_processes.append(p) @@ -163,10 +164,10 @@ for contig in contigs: command = "bsub "+EXCLUSIVE+" -q " + queue + " -R \"rusage[mem="+str(MEMORY_USAGE)+"]\" -o " + os.path.join(logs_dir,contig+"_log.txt") + " " + command if run: - print("Executing: " + command) if run_locally and num_parallel_processes > 1: execute(command, os.path.join(logs_dir,contig+"_log.txt")) else: + print("Executing: " + command) os.system(command) else: print(command)