feat: deploy to pypi

Author: ringoldsdev

.github/workflows/publish.yml

@@ -0,0 +1,35 @@
+name: Publish to PyPI
+
+on:
+  push:
+    tags:
+      - 'v*'  # Triggers on tags like v1.0.0, v1.2.3, etc.
+
+permissions:
+    id-token: write  # IMPORTANT: mandatory for trusted publishing
+
+jobs:
+  build:
+    name: Build distribution
+    runs-on: ubuntu-latest
+    environment:
+      name: pypi
+      url: https://pypi.org/p/laygo
+    steps:
+    - uses: actions/checkout@v4
+    
+    - name: Set up Python
+      uses: actions/setup-python@v5
+      with:
+        python-version: "3.12"
+
+    - name: Install uv
+      uses: astral-sh/setup-uv@v4
+      with:
+        enable-cache: true
+
+    - name: Build package
+      run: uv build
+
+    - name: Publish to PyPI
+      uses: pypa/gh-action-pypi-publish@release/v1

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2025 Ringolds Lescinskis
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

laygo/__init__.py

@@ -1,5 +1,19 @@
 """
-Laygo
+Laygo - A lightweight Python library for building resilient, in-memory data pipelines
 """
 
 __version__ = "0.1.0"
+
+from .errors import ErrorHandler
+from .helpers import PipelineContext
+from .pipeline import Pipeline
+from .transformers.parallel import ParallelTransformer
+from .transformers.transformer import Transformer
+
+__all__ = [
+  "Pipeline",
+  "Transformer",
+  "ParallelTransformer",
+  "PipelineContext",
+  "ErrorHandler",
+]

laygo/helpers.py

@@ -1,11 +1,10 @@
 from collections.abc import Callable
 import inspect
 from typing import Any
-from typing import TypedDict
 from typing import TypeGuard
 
 
-class PipelineContext(TypedDict):
+class PipelineContext(dict):
   """Generic, untyped context available to all pipeline operations."""
 
   pass

pyproject.toml

@@ -8,12 +8,32 @@ path = "laygo/__init__.py"
 [project]
 name = "laygo"
 dynamic = ["version"]
-description = "A Python CLI application"
+description = "A lightweight Python library for building resilient, in-memory data pipelines with elegant, chainable syntax"
 readme = "README.md"
 requires-python = ">=3.12"
+license = {text = "MIT"}
 authors = [
     {name = "Ringolds Lescinskis", email = "ringolds@lescinskis.com"},
 ]
+keywords = ["pipeline", "data-processing", "etl", "functional", "chaining"]
+classifiers = [
+    "Development Status :: 4 - Beta",
+    "Intended Audience :: Developers",
+    "License :: OSI Approved :: MIT License",
+    "Programming Language :: Python :: 3",
+    "Programming Language :: Python :: 3.12",
+    "Programming Language :: Python :: 3.13",
+    "Topic :: Software Development :: Libraries :: Python Modules",
+    "Topic :: Scientific/Engineering :: Information Analysis",
+    "Topic :: Utilities",
+    "Typing :: Typed",
+]
+
+[project.urls]
+Homepage = "https://github.com/ringoldsdev/laygo-python"
+Documentation = "https://github.com/ringoldsdev/laygo-python/wiki"
+Repository = "https://github.com/ringoldsdev/laygo-python.git"
+Issues = "https://github.com/ringoldsdev/laygo-python/issues"
 
 [project.optional-dependencies]
 dev = [

tests/test_integration.py

@@ -2,10 +2,10 @@
 
 import threading
 
-from laygo.pipeline import Pipeline
-from laygo.transformers.parallel import ParallelTransformer
-from laygo.transformers.transformer import PipelineContext
-from laygo.transformers.transformer import Transformer
+from laygo import ParallelTransformer
+from laygo import Pipeline
+from laygo import PipelineContext
+from laygo import Transformer
 
 
 class TestPipelineTransformerBasics:
@@ -19,7 +19,7 @@ def test_basic_pipeline_transformer_integration(self):
 
   def test_pipeline_context_sharing(self):
     """Test that context is properly shared between pipeline and transformers."""
-    context = {"multiplier": 3, "threshold": 5}
+    context = PipelineContext({"multiplier": 3, "threshold": 5})
     transformer = Transformer().map(lambda x, ctx: x * ctx["multiplier"]).filter(lambda x, ctx: x > ctx["threshold"])
     result = Pipeline([1, 2, 3]).context(context).apply(transformer).to_list()
     assert result == [6, 9]

tests/test_parallel_transformer.py

@@ -4,10 +4,10 @@
 import time
 from unittest.mock import patch
 
-from laygo.errors import ErrorHandler
-from laygo.transformers.parallel import ParallelTransformer
-from laygo.transformers.transformer import PipelineContext
-from laygo.transformers.transformer import Transformer
+from laygo import ErrorHandler
+from laygo import ParallelTransformer
+from laygo import PipelineContext
+from laygo import Transformer
 
 
 class TestParallelTransformerBasics:
@@ -76,7 +76,7 @@ def test_chained_operations(self):
 
   def test_flatten_operation(self):
     """Test flatten operation with concurrent execution."""
-    transformer = ParallelTransformer[list, int](max_workers=2, chunk_size=2).flatten()
+    transformer = ParallelTransformer[list[int], list[int]](max_workers=2, chunk_size=2).flatten()
     result = list(transformer([[1, 2], [3, 4], [5, 6]]))
     assert result == [1, 2, 3, 4, 5, 6]
 
@@ -308,7 +308,7 @@ def test_safe_with_error_isolation(self):
     errored_chunks = []
     transformer = ParallelTransformer.init(int, chunk_size=1).catch(
       lambda t: t.map(lambda x: x / 0),  # Division by zero
-      on_error=lambda chunk, error, context: errored_chunks.append(chunk),
+      on_error=lambda chunk, error, context: errored_chunks.append(chunk),  # type: ignore
     )
     result = list(transformer([1, 2, 3]))
 

tests/test_pipeline.py

@@ -1,7 +1,7 @@
 """Tests for the Pipeline class."""
 
-from laygo.pipeline import Pipeline
-from laygo.transformers.transformer import Transformer
+from laygo import Pipeline
+from laygo import Transformer
 
 
 class TestPipelineBasics:

tests/test_transformer.py

@@ -2,9 +2,9 @@
 
 import pytest
 
-from laygo.errors import ErrorHandler
-from laygo.transformers.transformer import PipelineContext
-from laygo.transformers.transformer import Transformer
+from laygo import ErrorHandler
+from laygo import PipelineContext
+from laygo import Transformer
 
 
 class TestTransformerBasics:
@@ -216,7 +216,7 @@ def test_catch_with_error_isolation(self):
     errored_chunks = []
     transformer = Transformer.init(int, chunk_size=1).catch(
       lambda t: t.map(lambda x: x / 0),  # Division by zero
-      on_error=lambda chunk, error, context: errored_chunks.append(chunk),
+      on_error=lambda chunk, error, context: errored_chunks.append(chunk),  # type: ignore
     )
     result = list(transformer([1, 2, 3]))
 
@@ -244,7 +244,7 @@ def set_error_flag(_chunk, _error, context):
       Transformer.init(int, chunk_size=1)
       .catch(
         lambda t: t.map(lambda x: x / 0),
-        on_error=set_error_flag,
+        on_error=set_error_flag,  # type: ignore
       )
       .short_circuit(lambda ctx: ctx.get("error_occurred", False))
     )
@@ -266,7 +266,7 @@ def raise_on_error(ctx):
       Transformer.init(int, chunk_size=1)
       .catch(
         lambda t: t.map(lambda x: x / 0),
-        on_error=set_error_flag,
+        on_error=set_error_flag,  # type: ignore
       )
       .short_circuit(raise_on_error)
     )