chore: bump version & style

Author: joschkabraun

cookbook/instructor/instructor_streaming.py

@@ -1,9 +1,9 @@
 import os
 
+import anthropic
 import instructor
 from dotenv import load_dotenv
 from openai import AsyncOpenAI
-import anthropic
 from pydantic import BaseModel
 
 from parea import Parea, trace
@@ -15,7 +15,7 @@
 
 p = Parea(api_key=os.getenv("PAREA_API_KEY"))
 
-p.wrap_openai_client(oai_aclient, 'instructor')
+p.wrap_openai_client(oai_aclient, "instructor")
 p.wrap_anthropic_client(ant_client)
 
 oai_aclient = instructor.from_openai(oai_aclient)

parea/utils/trace_integrations/instructor.py

@@ -1,7 +1,7 @@
-import logging
-from typing import Any, Callable, Mapping, Tuple, List
+from typing import Any, Callable, List, Mapping, Tuple
 
 import contextvars
+import logging
 from json import JSONDecodeError
 
 from instructor.retry import InstructorRetryException
@@ -91,13 +91,7 @@ def fn_transform_generator_outputs(items: List) -> str:
                     logger.warning(f"Failed to serialize generator output: {e}", exc_info=e)
                     return ""
 
-            return trace(
-                name=trace_name,
-                overwrite_trace_id=trace_id,
-                overwrite_inputs=inputs,
-                metadata=metadata,
-                fn_transform_generator_outputs=fn_transform_generator_outputs
-            )(
+            return trace(name=trace_name, overwrite_trace_id=trace_id, overwrite_inputs=inputs, metadata=metadata, fn_transform_generator_outputs=fn_transform_generator_outputs)(
                 wrapped
             )(*args, **kwargs)
         except (InstructorRetryException, ValidationError, JSONDecodeError) as e:

parea/wrapper/anthropic/anthropic.py

@@ -5,8 +5,7 @@
 from datetime import datetime
 
 from anthropic import AsyncMessageStreamManager, AsyncStream, Client, MessageStreamManager, Stream
-from anthropic.types import ContentBlockDeltaEvent, Message, MessageDeltaEvent, MessageStartEvent, TextBlock, \
-    InputJSONDelta, ToolUseBlock
+from anthropic.types import ContentBlockDeltaEvent, InputJSONDelta, Message, MessageDeltaEvent, MessageStartEvent, TextBlock, ToolUseBlock
 
 from parea.cache.cache import Cache
 from parea.helpers import timezone_aware_now

parea/wrapper/anthropic/stream_wrapper.py

@@ -3,7 +3,7 @@
 from types import TracebackType
 from typing import Callable
 
-from anthropic import AsyncMessageStreamManager, MessageStreamManager, Stream, AsyncStream
+from anthropic import AsyncMessageStreamManager, AsyncStream, MessageStreamManager, Stream
 from anthropic.types import Message
 
 

pyproject.toml

@@ -6,7 +6,7 @@ build-backend = "poetry.core.masonry.api"
 [tool.poetry]
 name = "parea-ai"
 packages = [{ include = "parea" }]
-version = "0.2.201"
+version = "0.2.202"
 description = "Parea python sdk"
 readme = "README.md"
 authors = ["joel-parea-ai <[email protected]>"]