diff --git a/pipeline.py b/pipeline.py index 6e847fb..066a418 100644 --- a/pipeline.py +++ b/pipeline.py @@ -200,8 +200,8 @@ class Components : base_cols = list(set(_args['data'].columns) - set(args['columns'])) #-- rebuilt the dataset (and store it) cols = _dc.columns.tolist() - # for name in cols : - # _args['data'][name] = _dc[name] + for name in cols : + _args['data'][name] = _dc[name] # info = {"module":"generate","action":"io","input":{"rows":_dc[name].shape[0],"name":name}} # if partition != '' : # info['partition'] = int(partition)