diff --git a/pipeline.py b/pipeline.py index 9aad2de..56e522e 100644 --- a/pipeline.py +++ b/pipeline.py @@ -652,8 +652,8 @@ if __name__ == '__main__' : DIRTY =1 jobs = [job for job in jobs if job.is_alive()] time.sleep(2) - # if DIRTY: - # print (["..:: jobs finished "]) + if DIRTY: + print (["..:: jobs finished "]) # # We need to harmonize the keys if any at all in this case we do this for shuffle or generate operations # @@ -662,7 +662,7 @@ if __name__ == '__main__' : # # We should pull all the primary keys and regenerate them in order to insure some form of consistency # - print (["..:: jobs finished "]) + print (["..:: Finalizing process"]) (Components()).finalize(args) # finalize(args) pass