From 2cee6db63b560d7cc3083110fb17dd0a328e76b5 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Wed, 31 May 2023 14:20:00 -0500 Subject: [PATCH] bug fix: ... --- bin/transport | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/bin/transport b/bin/transport index 8103cfe..8edaecc 100755 --- a/bin/transport +++ b/bin/transport @@ -70,12 +70,15 @@ if __name__ == '__main__' : procs = 1 if 'procs' not in SYS_ARGS else int(SYS_ARGS['procs']) jobs = transport.factory.instance(provider='etl',info=_info,procs=procs) + print ([len(jobs),' Jobs are running']) + N = len(jobs) while jobs : x = len(jobs) jobs = [_job for _job in jobs if _job.is_alive()] if x != len(jobs) : - print ([len(jobs),'... jobs running']) + print ([len(jobs),'... jobs still running']) time.sleep(1) + print ([N,' Finished running']) except Exception as e: print (e)