From 185158f006904484b1642be5bc86efeb887400c3 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Mon, 19 Jul 2021 19:42:51 -0500 Subject: [PATCH] bug fix: cli arguments source --- bin/transport | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/bin/transport b/bin/transport index 197e26e..48e6ff7 100644 --- a/bin/transport +++ b/bin/transport @@ -84,10 +84,11 @@ class ETL (Process): print (e) if __name__ == '__main__' : _info = json.loads(open (SYS_ARGS['config']).read()) - if 'source' in SYS_ARGS : - _info['source'] = {"type":"disk.DiskReader","args":{"path":SYS_ARGS['source'],"delimiter":","}} for _config in _info : + if 'source' in SYS_ARGS : + _config['source'] = {"type":"disk.DiskReader","args":{"path":SYS_ARGS['source'],"delimiter":","}} + _config['jobs'] = 10 if 'jobs' not in SYS_ARGS else SYS_ARGS['jobs'] etl = ETL (**_config) etl.start() \ No newline at end of file