A Python package for building fluent pipelines
Project description
FluentPipelines FluentPipelines is a Python package that simplifies the creation and execution of data processing pipelines.
Features
- Pipeline Creation: Easily create processing pipelines by chaining together operations.
- Flexible Operations: Define custom operations by subclassing
PipelineOperation
. - Convenient Interface: Intuitive
send
,through
,then
, andthen_return
methods for building and executing pipelines. - Error Handling: Robust error handling for smooth pipeline execution.
pip install fluentpipelines
Usage
Import PyPipeline
from fluentpipelines import pipeline
Define custom operations by subclassing PipelineOperation
class MyOperation(PipelineOperation):
def process(self, data):
# Define processing logic here
return processed_data
Create a pipeline
pipeline = pipeline.send(initial_data).through([MyOperation, AnotherOperation]).then_return()
Custom Operations
class MyOperation(PipelineOperation):
def process(self, data):
# Define processing logic here
return processed_data
Contributing
Contributions are welcome! Feel free to open issues or submit pull requests.
License
This project is licensed under the MIT License - see the LICENSE file for details.
Acknowledgments
This package was inspired by the need for a simple and flexible data pipeline solution.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
fluentpipelines-0.1.0.tar.gz
(2.5 kB
view hashes)
Built Distribution
Close
Hashes for fluentpipelines-0.1.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4ecf51156a7da0a085395ffe5064f1ee5abe9405fb26a9eb0a635803fe9031ce |
|
MD5 | d90dd409abd74d930d53453fa2a7159f |
|
BLAKE2b-256 | 94e7d7c4398d41dbe7725bead49544d412060e366af25ca78ed2a888a3e119ad |