Fix bug in pipeline

README.md

@@ -3,6 +3,13 @@
 <!-- PROJECT LOGO -->
 <p align="center"><img src="docs/logo.png" alt="logo" width="90%" height="90%"></p>
 
+| Overview | |
+|---|---|
+| **Open Source** |  [![BSD 3-clause](https://img.shields.io/badge/License-BSD%203--Clause-blue.svg)](https://github.com/ActurialCapital/blocks/blob/main/LICENSE) |
+| **Code** |  [![!pypi](https://img.shields.io/pypi/v/python-blocks?color=orange)](https://pypi.org/project/python-blocks/) [![!python-versions](https://img.shields.io/pypi/pyversions/python-blocks)](https://www.python.org/) |
+| **Downloads** | ![PyPI - Downloads](https://img.shields.io/pypi/dw/python-blocks) ![PyPI - Downloads](https://img.shields.io/pypi/dm/python-blocks) [![Downloads](https://static.pepy.tech/personalized-badge/python-blocks?period=total&units=international_system&left_color=grey&right_color=blue&left_text=cumulative%20(pypi))](https://pepy.tech/project/python-blocks) |
+
+
 <br>
 <!-- TABLE OF CONTENTS -->
 <details>

blocks/pipeline.py

@@ -381,7 +381,7 @@ def make_block_pipeline(*steps, **kwargs) -> BlockPipeline:
         The callback function that logs information in between each 
         intermediate step. If set to `"custom"`, `custom_log_callback` is 
         used. Defaults to None.
-        * `record_from` : str
+        * `record` : str
         Records named step data passed between each step of the pipeline at
         transform. The recorded data would become an attribute with named step 
         as name. If "all" is passed, it records all named step data. Default to 
@@ -391,7 +391,7 @@ def make_block_pipeline(*steps, **kwargs) -> BlockPipeline:
     -------
     BlockPipeline
         Instance with given steps, `memory`, `verbose`, `log_callback` and 
-        `record_from`.
+        `record`.
 
     Examples
     --------
@@ -489,7 +489,7 @@ def make_block_pipeline(*steps, **kwargs) -> BlockPipeline:
     memory = kwargs.pop("memory", None)
     verbose = kwargs.pop("verbose", False)
     log_callback = kwargs.pop("log_callback", None)
-    record_from = kwargs.pop("record_from", None)
+    record = kwargs.pop("record", None)
 
     if kwargs:
         raise TypeError(
@@ -501,5 +501,5 @@ def make_block_pipeline(*steps, **kwargs) -> BlockPipeline:
         memory=memory,
         verbose=verbose,
         log_callback=log_callback,
-        record_from=record_from,
+        record_from=record,
     )