library
/
data-transport
1
1
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

bug fix: ...

Browse Source
pull/1/head
Steve Nyemba 1 year ago
parent 7200be7beb
commit 2cee6db63b
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File

5
bin/transport
Unescape View File

@ -70,12 +70,15 @@ if __name__ == '__main__' :
procs = 1 if 'procs' not in SYS_ARGS else int(SYS_ARGS['procs']) procs = 1 if 'procs' not in SYS_ARGS else int(SYS_ARGS['procs'])
jobs = transport.factory.instance(provider='etl',info=_info,procs=procs) jobs = transport.factory.instance(provider='etl',info=_info,procs=procs)
print ([len(jobs),' Jobs are running'])
N = len(jobs)
while jobs : while jobs :
x = len(jobs) x = len(jobs)
jobs = [_job for _job in jobs if _job.is_alive()] jobs = [_job for _job in jobs if _job.is_alive()]
if x != len(jobs) : if x != len(jobs) :
print ([len(jobs),'... jobs running']) print ([len(jobs),'... jobs still running'])
time.sleep(1) time.sleep(1)
print ([N,' Finished running'])
except Exception as e: except Exception as e:
print (e) print (e)

Write Preview
Loading…
Cancel
Save