Permalink
Browse files

(experiment_runner_distribute - fix after changes to MockSgeQueuer)

Ignore-this: 18fd6ec9d8d9df7aa73e93eb17a5f911

darcs-hash:20130716155829-3a4db-607e82ce7e1d2fef1ea184e0454cf05e839d038e
  • Loading branch information...
1 parent 30d8ff7 commit 62c8a1c710505c01911a16bde773dcea412d73ca @MattShannon committed Jul 16, 2013
Showing with 7 additions and 11 deletions.
  1. +7 −11 expt_hts_demo/experiment_runner_distribute.py
@@ -22,9 +22,6 @@
def main(rawArgs):
buildRepo = qr.BuildRepo(base = os.path.join('expt_hts_demo', 'repo'))
- #queuer = qr.LocalQueuer(buildRepo = buildRepo)
- queuer = sge_queuer.MockSgeQueuer(buildRepo = buildRepo)
-
outDir = os.path.join('expt_hts_demo', 'out.d')
synthOutDir = os.path.join(outDir, 'synth')
figOutDir = os.path.join(outDir, 'fig')
@@ -38,14 +35,13 @@ def main(rawArgs):
finalArtifacts = experiment.doMonophoneSystemJobSet(synthOutDirArt,
figOutDirArt)
- live = queuer.generateArtifacts(finalArtifacts, verbosity = 1)
-
- finalLiveJobs = [ live[job.secHash()] for art in finalArtifacts
- for job in art.parents()
- if job.secHash() in live ]
-
- while not all([ liveJob.hasEnded() for liveJob in finalLiveJobs ]):
- time.sleep(0.1)
+ useLocalQueuer = False
+ if useLocalQueuer:
+ queuer = qr.LocalQueuer(buildRepo = buildRepo)
+ queuer.generateArtifacts(finalArtifacts, verbosity = 1)
+ else:
+ with sge_queuer.MockSgeQueuer(buildRepo = buildRepo) as queuer:
+ queuer.generateArtifacts(finalArtifacts, verbosity = 1)
print 'final values:'
for art in finalArtifacts:

0 comments on commit 62c8a1c

Please sign in to comment.