Skip to content

Commit

Permalink
optional anthropic and groq
Browse files Browse the repository at this point in the history
  • Loading branch information
jxnl committed Apr 3, 2024
1 parent b99b299 commit 213317d
Show file tree
Hide file tree
Showing 4 changed files with 135 additions and 109 deletions.
29 changes: 26 additions & 3 deletions instructor/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,14 +12,21 @@
from .function_calls import OpenAISchema, openai_schema
from .patch import apatch, patch
from .process_response import handle_parallel_model
from .client import Instructor, from_openai, from_anthropic, from_litellm, from_groq
from .client import (
Instructor,
AsyncInstructor,
from_openai,
from_litellm,
Provider,
)


__all__ = [
"Instructor",
"from_openai",
"from_anthropic",
"from_litellm",
"from_groq",
"AsyncInstructor",
"Provider",
"OpenAISchema",
"CitationMixin",
"IterableModel",
Expand All @@ -36,3 +43,19 @@
"handle_parallel_model",
"handle_response_model",
]

try:
import anthropic
from .client_anthropic import from_anthropic

__all__.append("from_anthropic")
except ImportError:
pass

try:
import groq
from .client_groq import from_groq

__all__.append("from_groq")
except ImportError:
pass
111 changes: 5 additions & 106 deletions instructor/client.py
Original file line number Diff line number Diff line change
@@ -1,8 +1,6 @@
import openai
import inspect
import instructor
import anthropic
import groq
from .utils import Provider, get_provider
from openai.types.chat import ChatCompletion, ChatCompletionMessageParam
from anthropic.types import Message
Expand All @@ -29,15 +27,15 @@


class Instructor:
client: openai.OpenAI | anthropic.Anthropic | None
client: Any | None
create_fn: Any
mode: instructor.Mode
default_model: str | None = None
provider: Provider

def __init__(
self,
client: openai.OpenAI | anthropic.Anthropic | None,
client: Any | None,
create: Callable,
mode: instructor.Mode = instructor.Mode.TOOLS,
provider: Provider = Provider.OPENAI,
Expand Down Expand Up @@ -151,15 +149,15 @@ def handle_kwargs(self, kwargs: dict):


class AsyncInstructor(Instructor):
client: openai.AsyncOpenAI | anthropic.AsyncAnthropic | None
client: Any | None
create_fn: Any
mode: instructor.Mode
default_model: str | None = None
provider: Provider

def __init__(
self,
client: openai.AsyncOpenAI | anthropic.AsyncAnthropic | None,
client: Any | None,
create: Callable,
mode: instructor.Mode = instructor.Mode.TOOLS,
provider: Provider = Provider.OPENAI,
Expand Down Expand Up @@ -282,10 +280,7 @@ def from_openai(
instructor.Mode.JSON,
instructor.Mode.JSON_SCHEMA,
}
if provider in {Provider.GROQ}:
assert mode in {
instructor.Mode.MD_JSON,
}

if provider in {Provider.OPENAI}:
assert mode in {
instructor.Mode.TOOLS,
Expand Down Expand Up @@ -352,99 +347,3 @@ def from_litellm(
mode=mode,
**kwargs,
)


@overload
def from_anthropic(
client: anthropic.Anthropic,
mode: instructor.Mode = instructor.Mode.ANTHROPIC_JSON,
**kwargs,
) -> Instructor: ...


@overload
def from_anthropic(
client: anthropic.AsyncAnthropic,
mode: instructor.Mode = instructor.Mode.ANTHROPIC_JSON,
**kwargs,
) -> Instructor: ...


def from_anthropic(
client: anthropic.Anthropic | anthropic.AsyncAnthropic,
mode: instructor.Mode = instructor.Mode.ANTHROPIC_JSON,
**kwargs,
) -> Instructor | AsyncInstructor:
assert mode in {
instructor.Mode.ANTHROPIC_JSON,
instructor.Mode.ANTHROPIC_TOOLS,
}, "Mode be one of {instructor.Mode.ANTHROPIC_JSON, instructor.Mode.ANTHROPIC_TOOLS}"

assert isinstance(
client, (anthropic.Anthropic, anthropic.AsyncAnthropic)
), "Client must be an instance of anthropic.Anthropic or anthropic.AsyncAnthropic"

if isinstance(client, anthropic.Anthropic):
return Instructor(
client=client,
create=instructor.patch(create=client.messages.create, mode=mode),
provider=Provider.ANTHROPIC,
mode=mode,
**kwargs,
)

else:
return AsyncInstructor(
client=client,
create=instructor.patch(create=client.messages.create, mode=mode),
provider=Provider.ANTHROPIC,
mode=mode,
**kwargs,
)


@overload
def from_groq(
client: groq.Groq,
mode: instructor.Mode = instructor.Mode.TOOLS,
**kwargs,
) -> Instructor: ...


@overload
def from_groq(
client: groq.Groq,
mode: instructor.Mode = instructor.Mode.TOOLS,
**kwargs,
) -> Instructor: ...


def from_groq(
client: groq.Groq,
mode: instructor.Mode = instructor.Mode.TOOLS,
**kwargs,
) -> Instructor:
assert mode in {
instructor.Mode.JSON,
instructor.Mode.TOOLS,
}, "Mode be one of {instructor.Mode.JSON, instructor.Mode.TOOLS}"

assert isinstance(client, (groq.Groq)), "Client must be an instance of groq.GROQ"

if isinstance(client, groq.Groq):
return Instructor(
client=client,
create=instructor.patch(create=client.chat.completions.create, mode=mode),
provider=Provider.GROQ,
mode=mode,
**kwargs,
)

else:
return AsyncInstructor(
client=client,
create=instructor.patch(create=client.messages.create, mode=mode),
provider=Provider.GROQ,
mode=mode,
**kwargs,
)
53 changes: 53 additions & 0 deletions instructor/client_anthropic.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,53 @@
import anthropic
import instructor

from typing import overload


@overload
def from_anthropic(
client: anthropic.Anthropic,
mode: instructor.Mode = instructor.Mode.ANTHROPIC_JSON,
**kwargs,
) -> instructor.Instructor: ...


@overload
def from_anthropic(
client: anthropic.AsyncAnthropic,
mode: instructor.Mode = instructor.Mode.ANTHROPIC_JSON,
**kwargs,
) -> instructor.Instructor: ...


def from_anthropic(
client: anthropic.Anthropic | anthropic.AsyncAnthropic,
mode: instructor.Mode = instructor.Mode.ANTHROPIC_JSON,
**kwargs,
) -> instructor.Instructor | instructor.AsyncInstructor:
assert mode in {
instructor.Mode.ANTHROPIC_JSON,
instructor.Mode.ANTHROPIC_TOOLS,
}, "Mode be one of {instructor.Mode.ANTHROPIC_JSON, instructor.Mode.ANTHROPIC_TOOLS}"

assert isinstance(
client, (anthropic.Anthropic, anthropic.AsyncAnthropic)
), "Client must be an instance of anthropic.Anthropic or anthropic.AsyncAnthropic"

if isinstance(client, anthropic.Anthropic):
return instructor.Instructor(
client=client,
create=instructor.patch(create=client.messages.create, mode=mode),
provider=instructor.Provider.ANTHROPIC,
mode=mode,
**kwargs,
)

else:
return instructor.AsyncInstructor(
client=client,
create=instructor.patch(create=client.messages.create, mode=mode),
provider=instructor.Provider.ANTHROPIC,
mode=mode,
**kwargs,
)
51 changes: 51 additions & 0 deletions instructor/client_groq.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,51 @@
from typing import overload

import groq
import instructor


@overload
def from_groq(
client: groq.Groq,
mode: instructor.Mode = instructor.Mode.TOOLS,
**kwargs,
) -> instructor.Instructor: ...


@overload
def from_groq(
client: groq.Groq,
mode: instructor.Mode = instructor.Mode.TOOLS,
**kwargs,
) -> instructor.Instructor: ...


def from_groq(
client: groq.Groq,
mode: instructor.Mode = instructor.Mode.TOOLS,
**kwargs,
) -> instructor.Instructor:
assert mode in {
instructor.Mode.JSON,
instructor.Mode.TOOLS,
}, "Mode be one of {instructor.Mode.JSON, instructor.Mode.TOOLS}"

assert isinstance(client, (groq.Groq)), "Client must be an instance of groq.GROQ"

if isinstance(client, groq.Groq):
return instructor.Instructor(
client=client,
create=instructor.patch(create=client.chat.completions.create, mode=mode),
provider=instructor.Provider.GROQ,
mode=mode,
**kwargs,
)

else:
return instructor.Instructor(
client=client,
create=instructor.patch(create=client.messages.create, mode=mode),
provider=instructor.Provider.GROQ,
mode=mode,
**kwargs,
)

0 comments on commit 213317d

Please sign in to comment.