Skip to main content

A professional collection of pre-built steps and states for the WPipe orchestration engine.

Project description

🧱 WPipe Steps

A professional collection of pre-built, production-ready steps and states for the WPipe orchestration engine.

WPipe Steps provides a comprehensive library of modular components ("Steps") that can be easily integrated into your WPipe pipelines. Instead of reinventing the wheel for common tasks like API calls, database queries, or notifications, simply import and use a pre-built step.


📂 Professional Structure

The library is organized into logical "Packs" based on functionality:

Pack Namespace Description
🌐 Connectivity wpipe_steps.connectivity HttpRequestStep: REST/APIs client.
GraphQLQueryStep: GraphQL query/mutation executor.
📊 Database wpipe_steps.database MySQL, Redis, MongoDB, ClickHouse, SQLite.
🛡️ Security wpipe_steps.security Nmap, Shodan, Vault, Inyection Filtering.
☁️ Infrastructure wpipe_steps.infrastructure AWS S3, Docker, Kubernetes, Terraform.
📧 Communication wpipe_steps.communication Telegram, Slack, Discord, SendGrid, Twilio.
📁 Data wpipe_steps.data CSV, JSON, PDF, Excel, Image Processing.
🎙️ Multimedia wpipe_steps.multimedia Audio Normalization, Whisper AI, TTS.
🤖 AI wpipe_steps.ai OpenAI, HuggingFace, Sentiment Analysis.
⚙️ System wpipe_steps.system Resource Monitoring, Shell Exec, Health Checks.

🚀 Quick Start

Installation

pip install wpipe-steps

Basic Usage

from wpipe import Pipeline
from wpipe_steps.connectivity import HttpRequestStep

# Create a pipeline
pipeline = Pipeline(pipeline_name="fetch_api")

# Use a pre-built step
pipeline.set_steps([
    HttpRequestStep.as_step(
        name="fetch_user",
        url="https://api.example.com/user/1",
        method="GET"
    )
])

pipeline.run({})

🛠️ Developer Guide: Creating a New Step

All steps should inherit from BaseStep located in wpipe_steps.core.base.

from wpipe_steps.core.base import BaseStep

class MyCustomStep(BaseStep):
    def execute(self, data):
        # Your logic here
        data["my_key"] = "my_value"
        return data

📢 Roadmap

Check the TODO.txt for the full list of planned steps for each pack.


Diseñado con ❤️ por William Rodriguez (wisrovi) para ingenieros que buscan máxima productividad.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

wpipe_steps-0.3.0.tar.gz (78.9 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

wpipe_steps-0.3.0-py3-none-any.whl (8.1 kB view details)

Uploaded Python 3

File details

Details for the file wpipe_steps-0.3.0.tar.gz.

File metadata

  • Download URL: wpipe_steps-0.3.0.tar.gz
  • Upload date:
  • Size: 78.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.13.5

File hashes

Hashes for wpipe_steps-0.3.0.tar.gz
Algorithm Hash digest
SHA256 65a0c6f1690093b9c64c1cb59ccffa00819deb7550d2aeb8327f5cd0a7ff5c64
MD5 a69a8af97ab0a6fa106babbef893f366
BLAKE2b-256 c780b5f3867baaa2c27ac4e06c362144ed2bc7d5bd8b2cf655841cf4f1731913

See more details on using hashes here.

File details

Details for the file wpipe_steps-0.3.0-py3-none-any.whl.

File metadata

  • Download URL: wpipe_steps-0.3.0-py3-none-any.whl
  • Upload date:
  • Size: 8.1 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.13.5

File hashes

Hashes for wpipe_steps-0.3.0-py3-none-any.whl
Algorithm Hash digest
SHA256 a119e00dce95ef44516ae3d187fbfd5fc1c3f671e158c231c421d8fb92e53d33
MD5 fe8238cbcd5c5b502b2df6083ba00ed4
BLAKE2b-256 1e404b594c65bf8f9ed3003349c230958f0e59657f536ac8435959b64231c434

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page