From d3416631bb0488c40d0f44018e67df979abea5f1 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Mon, 19 Jul 2021 19:40:36 -0500 Subject: [PATCH] bug fix: cli arguments source --- bin/transport | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/bin/transport b/bin/transport index b07483e..197e26e 100644 --- a/bin/transport +++ b/bin/transport @@ -84,7 +84,8 @@ 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 : _config['jobs'] = 10 if 'jobs' not in SYS_ARGS else SYS_ARGS['jobs']