create_data_reducer
===================

.. currentmodule:: pipeline.infrastructure.callibrary

.. autofunction:: create_data_reducer