diff --git a/pipeline.py b/pipeline.py index 884609f..7620afd 100644 --- 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 :