diff --git a/pipeline.py b/pipeline.py index 65eda3e..15d562a 100644 --- a/pipeline.py +++ b/pipeline.py @@ -269,7 +269,8 @@ if __name__ == '__main__' : if 'file' in args : reader = lambda: pd.read_csv(args['file']) ; else: - reader = lambda: Components().get(args) + _df = Components().get(args) + reader = lambda: _df args['reader'] = reader if 'generate' in SYS_ARGS :