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 executor.
WebhookTriggerStep: External webhook notifier.
📊 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.4.0.tar.gz (79.5 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.4.0-py3-none-any.whl (9.1 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: wpipe_steps-0.4.0.tar.gz
  • Upload date:
  • Size: 79.5 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.4.0.tar.gz
Algorithm Hash digest
SHA256 40dc4a9428588b8527a7adbb58fd5207e8ff2ca5e257f2d9c0c2ce0711078f1e
MD5 46a6318baefc4017c57660dbc2bb2a1a
BLAKE2b-256 3f52b0fc858a083f2742dcbaf53d7834f36e617bbe08e147697577dca2b34476

See more details on using hashes here.

File details

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

File metadata

  • Download URL: wpipe_steps-0.4.0-py3-none-any.whl
  • Upload date:
  • Size: 9.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.4.0-py3-none-any.whl
Algorithm Hash digest
SHA256 ce847ca036cd3a60a5c76dc681d6af611b5ead811e6faab39bfa49349ad508ba
MD5 efd85f5f09e2ed4803816864c47d91d4
BLAKE2b-256 bad5df161bea9ee7e7d5cec7e9f1da56e29f4b5e987d71af1a621ba78264211f

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