docs: update instructor streaming cookbook

Author: joschkabraun

cookbook/instructor/instructor_streaming.py

@@ -3,61 +3,79 @@
 import instructor
 from dotenv import load_dotenv
 from openai import AsyncOpenAI
+import anthropic
+from pydantic import BaseModel
 
-from parea import Parea
+from parea import Parea, trace
 
 load_dotenv()
 
-client = AsyncOpenAI()
+oai_aclient = AsyncOpenAI()
+ant_client = anthropic.AsyncClient()
 
 p = Parea(api_key=os.getenv("PAREA_API_KEY"))
-p.wrap_openai_client(client, "instructor")
-
-client = instructor.from_openai(client)
 
+p.wrap_openai_client(oai_aclient, 'instructor')
+p.wrap_anthropic_client(ant_client)
 
-from pydantic import BaseModel
+oai_aclient = instructor.from_openai(oai_aclient)
+ant_client = instructor.from_anthropic(ant_client)
 
 
 class UserDetail(BaseModel):
     name: str
-    age: int
+    age: str
 
 
-async def main():
-    user = client.completions.create_partial(
-        model="gpt-3.5-turbo",
+@trace
+async def ainner_main():
+    user = oai_aclient.completions.create_partial(
+        model="gpt-4o-mini",
         max_tokens=1024,
         max_retries=3,
         messages=[
             {
                 "role": "user",
-                "content": "Please crea a user",
+                "content": "Please create a user",
             }
         ],
         response_model=UserDetail,
     )
-    # print(user)
-    async for u in user:
+    return user
+
+
+async def amain():
+    resp = await ainner_main()
+    async for u in resp:
         print(u)
 
-    # user2 = client.completions.create_partial(
-    #     model="gpt-3.5-turbo",
-    #     max_tokens=1024,
-    #     max_retries=3,
-    #     messages=[
-    #         {
-    #             "role": "user",
-    #             "content": "Please crea a user",
-    #         }
-    #     ],
-    #     response_model=UserDetail,
-    # )
-    # async for u in user2:
-    #     print(u)
+
+@trace
+def inner_main():
+    user = ant_client.completions.create_partial(
+        model="claude-3-5-sonnet-20240620",
+        max_tokens=1024,
+        max_retries=3,
+        messages=[
+            {
+                "role": "user",
+                "content": "Please create a user",
+            }
+        ],
+        response_model=UserDetail,
+    )
+    return user
+
+
+def main():
+    resp = inner_main()
+    for u in resp:
+        print(u)
 
 
 if __name__ == "__main__":
     import asyncio
 
-    asyncio.run(main())
+    asyncio.run(amain())
+
+    main()