diff --git a/pipeline.py b/pipeline.py index 78ffefe..4985156 100644 --- a/pipeline.py +++ b/pipeline.py @@ -152,6 +152,7 @@ class Components : # reader = args['reader'] # df = reader() df = args['reader']() if 'reader' in args else args['data'] + # bounds = Components.split(df,MAX_ROWS,PART_SIZE) # if partition != '' : # columns = args['columns'] @@ -168,7 +169,7 @@ class Components : # -- Let us tray assessing - df = np.array_split(df,N) + _dc = pd.DataFrame() # for mdf in df : _args['data'] = df