Permalink
Browse files

Queue manager and work nodes concurrently; fixes issue 50 reported by @…

  • Loading branch information...
1 parent 13ed832 commit 465d0fdc482bcb5ac0f354f9b825537531cf5789 @chapmanb committed Mar 1, 2012
Showing with 3 additions and 2 deletions.
  1. +3 −2 nextgen/bcbio/distributed/manage.py
@@ -61,8 +61,9 @@ def start_analysis_manager(cluster, args, config):
program_cl = [config["analysis"]["process_program"]] + args
job_id = cluster.submit_job(cluster_args, program_cl)
# wait for job to start
- while not(cluster.are_running([job_id])):
- time.sleep(5)
+ # Avoid this for systems where everything queues as batches
+ #while not(cluster.are_running([job_id])):
+ # time.sleep(5)
return job_id
def monitor_analysis(cluster, job_id):

0 comments on commit 465d0fd

Please sign in to comment.