👌 IMPROVE: Pipes Type

Author: arre-ankit

CONTRIBUTION.md

@@ -17,11 +17,11 @@ def main():
     langbase_api_key = os.getenv("LANGBASE_API_KEY")
 
     # Initialize the client
-    lb = Langbase(api_key=langbase_api_key)
+    langbase = Langbase(api_key=langbase_api_key)
 
     # Create the pipe
     try:
-        response = lb.pipes.create(
+        response = langbase.pipes.create(
             name="summary-agent",
             description="A pipe for text summarization",
             messages=[

examples/agent/agent.run.typed-stream.py

@@ -38,6 +38,25 @@
 )
 from .langbase import Langbase
 from .streaming import StreamEventType, TypedStreamProcessor
+from .types import (
+    ChoiceGenerate,
+    Message,
+    PipeBaseOptions,
+    PipeBaseResponse,
+    PipeCreateOptions,
+    PipeCreateResponse,
+    PipeListResponse,
+    PipeUpdateOptions,
+    PipeUpdateResponse,
+    ResponseFormat,
+    RunResponse,
+    RunResponseStream,
+    ToolCall,
+    ToolChoice,
+    Tools,
+    Usage,
+    Variable,
+)
 from .workflow import TimeoutError, Workflow
 
 __version__ = "0.1.0"
@@ -61,10 +80,26 @@
     "RateLimitError",
     "TimeoutError",
     "UnprocessableEntityError",
+    # Type definitions
+    "ChoiceGenerate",
+    "Message",
+    "PipeBaseOptions",
+    "PipeBaseResponse",
+    "PipeCreateOptions",
+    "PipeCreateResponse",
+    "PipeListResponse",
+    "PipeUpdateOptions",
+    "PipeUpdateResponse",
+    "ResponseFormat",
+    "RunResponse",
+    "RunResponseStream",
+    "ToolCall",
+    "ToolChoice",
+    "Tools",
+    "Usage",
+    "Variable",
     # Helper utilities
-    "ChoiceStream",
     "ChunkStream",
-    "Delta",
     "StreamProcessor",
     "collect_stream_text",
     "create_stream_processor",