pyline-core 2.2.1

pyline core

PyLine Core

A lightweight Python framework for implementing the Command Query Responsibility Segregation (CQRS) pattern with pipeline orchestration capabilities.

🚀 Key Features

• CQRS Implementation: Strong separation between Commands (write) and Queries (read).
• Mediator Pattern: Decouple components with a centralized handler registration.
• Pipeline Orchestration: Execute sequences of steps with a shared context and automatic parameter mapping.
• Type-Safe: Modern Python type hints with @overload support for superior developer experience.
• Micro-Framework: Ultra-lightweight with zero external dependencies in core.

📦 Installation

pip install pyline-core

🚥 Quick Start

1. Define Components

from pyline import Command, Query, CommandHandler, QueryHandler
from dataclasses import dataclass

@dataclass
class CreateUserCommand(Command):
    name: str

class CreateUserCommandHandler(CommandHandler):
    async def handle(self, command: CreateUserCommand) -> None:
        print(f"Creating user: {command.name}")

@dataclass
class GetUserQuery(Query):
    name: str

class GetUserQueryHandler(QueryHandler):
    async def handle(self, query: GetUserQuery):
        return {"id": 1, "name": query.name}

2. Register and Execute

from pyline import mediator

# Registration
mediator.register_handler(CreateUserCommand, CreateUserCommandHandler())
mediator.register_handler(GetUserQuery, GetUserQueryHandler())

# Execution
async def main():
    await mediator.send(CreateUserCommand(name="Alp"))
    user = await mediator.send(GetUserQuery(name="Alp"))
    print(user)

🛠 Advanced: Pipeline Orchestration

Chain multiple commands and queries into a single workflow with shared context:

from pyline.pipe import Pipe

pipe = Pipe(
    name="Registration Flow",
    context={"name": "John Doe"},
    steps=[CreateUserCommand, GetUserQuery]
)

await pipe.run()

📖 Documentation

For detailed guides and full API reference, visit our documentation site (coming soon).

🤝 Contributing

Contributions are welcome! Please see CONTRIBUTING.md for local development setup and standards.

📄 License

MIT. See LICENSE for details.