bug fix: epochs, process control (generator)

5 years ago · 205adf8fa6
parent 6e0f89cd3c
commit 205adf8fa6
1 changed files with 2 additions and 0 deletions
--- a/pipeline.py
+++ b/pipeline.py
@ -327,6 +327,8 @@ if __name__ == '__main__' :
 				job.name = 'generator # '+str(index)
 				job.start()
 				jobs.append(job)
+				if len(jobs) == 1 :
+					job.join()

 			print (["Started ",len(jobs),"generators" if len(jobs)>1 else "generator" ])
 			while len(jobs)> 0 :