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`, and `then_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.
Raw data
{
"_id": null,
"home_page": "https://github.com/JarriqTheTechie/fluentpipelines",
"name": "fluentpipelines",
"maintainer": "",
"docs_url": null,
"requires_python": ">=3.9",
"maintainer_email": "",
"keywords": "",
"author": "Jarriq Rolle",
"author_email": "jrolle@bnbbahamas.com",
"download_url": "https://files.pythonhosted.org/packages/b8/57/7c872106ea62af8038d23e146cad28babdb3b87f88f0431dcf58576a65bc/fluentpipelines-0.1.1.tar.gz",
"platform": null,
"description": "FluentPipelines\r\nFluentPipelines is a Python package that simplifies the creation and execution of data processing pipelines.\r\n\r\n## Features\r\n\r\n- **Pipeline Creation**: Easily create processing pipelines by chaining together operations.\r\n- **Flexible Operations**: Define custom operations by subclassing `PipelineOperation`.\r\n- **Convenient Interface**: Intuitive `send`, `through`, `then`, and `then_return` methods for building and executing pipelines.\r\n- **Error Handling**: Robust error handling for smooth pipeline execution.\r\n\r\n```\r\npip install fluentpipelines\r\n```\r\n# Usage\r\n\r\n\r\n### Import PyPipeline\r\n```\r\nfrom fluentpipelines import pipeline\r\n```\r\n\r\n### Define custom operations by subclassing PipelineOperation\r\n```\r\nclass MyOperation(PipelineOperation):\r\n def process(self, data):\r\n # Define processing logic here\r\n return processed_data\r\n```\r\n\r\n### Create a pipeline\r\n```\r\npipeline = pipeline.send(initial_data).through([MyOperation, AnotherOperation]).then_return()\r\n```\r\n\r\n### Custom Operations\r\n```\r\nclass MyOperation(PipelineOperation):\r\n def process(self, data):\r\n # Define processing logic here\r\n return processed_data\r\n```\r\n\r\n\r\n## Contributing\r\nContributions are welcome! Feel free to open issues or submit pull requests.\r\n\r\n## License\r\nThis project is licensed under the MIT License - see the LICENSE file for details.\r\n\r\n## Acknowledgments\r\nThis package was inspired by the need for a simple and flexible data pipeline solution.\r\n",
"bugtrack_url": null,
"license": "",
"summary": "A Python package for building fluent pipelines",
"version": "0.1.1",
"project_urls": {
"Homepage": "https://github.com/JarriqTheTechie/fluentpipelines"
},
"split_keywords": [],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "e2c53ab57bf1aaf54139ca6bc1dd46e660f2a272f8f4ca90bb8fc1d1b25d7d31",
"md5": "96a27ea7bd5304892598990d6ef90e1b",
"sha256": "34930a46f36b98df2f825a129adbe1b599f3fbecc3694ab37306d89b807dc731"
},
"downloads": -1,
"filename": "fluentpipelines-0.1.1-py3-none-any.whl",
"has_sig": false,
"md5_digest": "96a27ea7bd5304892598990d6ef90e1b",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": ">=3.9",
"size": 2950,
"upload_time": "2023-12-03T19:21:08",
"upload_time_iso_8601": "2023-12-03T19:21:08.294201Z",
"url": "https://files.pythonhosted.org/packages/e2/c5/3ab57bf1aaf54139ca6bc1dd46e660f2a272f8f4ca90bb8fc1d1b25d7d31/fluentpipelines-0.1.1-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "b8577c872106ea62af8038d23e146cad28babdb3b87f88f0431dcf58576a65bc",
"md5": "b76b0222347857922a80c9ebb3993379",
"sha256": "70baf777e983866fa1289e831fdfca67dc888d55ed08b8786debdf1fde00938a"
},
"downloads": -1,
"filename": "fluentpipelines-0.1.1.tar.gz",
"has_sig": false,
"md5_digest": "b76b0222347857922a80c9ebb3993379",
"packagetype": "sdist",
"python_version": "source",
"requires_python": ">=3.9",
"size": 2517,
"upload_time": "2023-12-03T19:21:10",
"upload_time_iso_8601": "2023-12-03T19:21:10.089991Z",
"url": "https://files.pythonhosted.org/packages/b8/57/7c872106ea62af8038d23e146cad28babdb3b87f88f0431dcf58576a65bc/fluentpipelines-0.1.1.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2023-12-03 19:21:10",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "JarriqTheTechie",
"github_project": "fluentpipelines",
"travis_ci": false,
"coveralls": false,
"github_actions": false,
"lcname": "fluentpipelines"
}
JSON
