Utilities

Callback handler for promptlayer.

Upstash Ratelimit Error

Callback to handle rate limiting based on the number of requests

Label Studio mode enumerator.

Label Studio callback handler.

Callback handler that is used within a Flyte task.

Callback Handler that records transcripts to the Context service.

Callback Handler that tracks bedrock anthropic info.

Handle the metadata and associated function states for callbacks.

Callback Handler that logs metrics and artifacts to mlflow server.

Callback Handler that logs metrics and artifacts to mlflow server.

Token type enum.

Callback Handler that tracks OpenAI info.

Callback Handler that logs to ClearML.

Callback Handler that logs prompt artifacts and metrics to SageMaker Experiments.

The UpTrain data schema for tracking evaluation results.

Callback Handler that logs evaluation results to uptrain and the console.

Callback Handler that logs to Arize.

Exception to raise when a person manually review and rejects a value.

Callback for manually validating values.

Asynchronous callback for manually validating values.

Callback Handler that logs to Comet.

Callback handler for the metadata and associated function states for callbacks.

Callback Handler that logs to Aim.

Callback Handler that logs to Arthur platform.

Context manager for LLMonitor user context.

Callback Handler for LLMonitor`.

Callback Handler that logs to Infino.

Callback Handler that logs into Argilla.

Callback Handler that logs into deepeval.

Callback handler for Trubrics.

Callback Handler that logs to Weights and Biases.

Callback Handler for logging to WhyLabs. This callback handler utilizes

Enumerator of the LLMThought state.

Tool record as a NamedTuple.

Generates markdown labels for LLMThought containers. Pass a custom

A thought in the LLM's thought stream.

Callback handler that writes to a Streamlit app.

Enumerator of the child type.

Child record as a NamedTuple.

Streamlit expander that can be renamed and dynamically expanded/collapsed.

Comet Tracer.

Arguments for the WandbTracer.

Callback Handler that logs to Weights and Biases.

Chain that requests a URL and then uses an LLM to parse results.

Parse the response and error tags.

Get the response parser.

Parse the request and error tags.

Get the request parser.

Chain interacts with an OpenAPI endpoint using natural language.

Question-answering against Ontotext GraphDB

Question-answering against a graph by generating Cypher statements for Kùzu.

Chain for question-answering against a graph by generating Cypher statements.

Chain for question-answering against a graph by generating gremlin statements.

Chain for question-answering against a graph by generating gremlin statements.

Chain for question-answering against a graph by generating nGQL statements.

Question-answering against an RDF or OWL graph by generating SPARQL statements.

Chain for question-answering against a graph by generating Cypher statements.

Chain for question-answering against a graph by generating AQL statements.

Chain for question-answering against a graph.

Routes available for the Pebblo API as enumerator.

Wrapper for Pebblo Retrieval API.

Class for an authorization context.

Class for a semantic entity filter.

Class for a semantic topic filter.

Class for a semantic context.

Input for PebbloRetrievalQA chain.

OS, language details

Langchain framework details

Retrieval Chain with Identity & Semantic Enforcement for question-answering

Dict like wrapper around search api results.

Wrapper for Searx API.

Access to the TensorFlow Datasets.

Wrapper for AskNews API.

Wrapper for OpenAI's DALL-E Image Generator.

Wrapper for AWS Lambda SDK.

Wrapper around the Serper.dev Google Search API.

Metadata on a single hit from you.com

A single hit from you.com, which may contain multiple snippets

Output from you.com API.

Output of parsing one snippet.

Wrapper for you.com Search and News API.

Routes available for the Pebblo API as enumerator.

Pebblo Indexed Document.

Pebblo Runtime.

Pebblo Framework instance.

Pebblo AI application.

Pebblo document.

Wrapper for Pebblo Loader API.

Wrapper for DuckDuckGo Search API.

Wrapper for AlphaVantage API for Currency Exchange Rate.

Base class for all components.

Class for a task.

Component class for a list.

Component class for a member.

Component class for a team.

Component class for a space.

Wrapper for Clickup API.

Wrapper around Google Places API.

Wrapper for Reddit API

Wrapper for SerpApi's Google Scholar API

Wrapper for NASA API.

Wrapper around semanticscholar.org API.

Wrapper around Dria API.

Wrapper around the Jina search engine.

Portkey configuration.

Wrapper for Tavily Search API.

Wrapper around requests to handle auth and async.

Lightweight wrapper around requests library.

Lightweight wrapper around requests library, with async support.

Lightweight wrapper around requests library, with async support.

Wrapper for GitLab API.

Wrapper for Rememberizer APIs.

Wrapper for Zapier NLA.

Wrapper around Google Books API.

Wrapper for Merriam-Webster.

Context manager to hide prints.

Wrapper around SerpAPI.

Wrapper around ArxivAPI.

Wrapper around bibtexparser.

Messaging Client using Twilio.

Jira OAuth2 token.

Jira OAuth2.

Wrapper for Jira API. You can connect to Jira with either an API token or OAuth2.

Create PowerBI engine from dataset ID and credential or token.

Wrapper for financial datasets API.

Wrapper for SerpApi's Google Scholar API

Wrapper around GraphQL API.

Wrapper for Bing Web Search API.

Interface for querying Alibaba Cloud MaxCompute tables.

Wrapper for Steam API.

SQLAlchemy wrapper around a database.

Wrapper for OpenWeatherMap API using PyOWM.

Wrapper around SearchApi API.

Enumerator of the HTTP verbs.

OpenAPI Model that removes mis-formatted parts of the spec.

Wrapper for Stack Exchange API.

Wrapper for Polygon API.

Apache Cassandra® database wrapper.

Exception raised for errors in the database schema.

SparkSQL is a utility class for interacting with Spark SQL.

Mixin to prevent storing on disk.

Manage the token for the NutritionAI API.

Wrapper for the Passio Nutrition AI API.

Wrapper for SceneXplain API.

An empty Sentinel type.

An enum of the possible choices for Riva audio encoding.

Configuration for the authentication to a Riva service connection.

A collection of common Riva settings.

A message containing streaming audio.

A runnable that performs Automatic Speech Recognition (ASR) using NVIDIA Riva.

A runnable that performs Text-to-Speech (TTS) with NVIDIA Riva.

Wrapper for Wolfram Alpha.

Wrapper for Google Scholar API

Wrapper for Golden.

Wrapper for Infobip API for messaging.

Wrapper for SerpApi's Google Lens API

Wrapper around the Wikidata API.

Wrapper for Metaphor Search API.

Wrapper around OutlineAPI.

Escape punctuation within an input string.

Wrapper around WikipediaAPI.

Wrapper for SerpApi's Google Finance API

Wrapper around PubMed API.

Setup mode for AstraDBEnvironment as enumerator.

Routes available for the Arcee API as enumerator.

Filter types available for a DALM retrieval as enumerator.

Filters available for a DALM retrieval and generation.

Source of an Arcee document.

Arcee document.

Adapter for Arcee documents

Wrapper for Arcee API.

Wrapper around the Brave search engine.

Wrapper for Dataherald.

Wrapper around the DataForSeo API.

Wrapper for GitHub API.

Representation of a callable function to the Ernie API.

Representation of a callable function to the Ernie API.

Parse the output of an LLM call using Guardrails.

Parse an output that is one of sets of values.

Parse an output as the Json object.

Parse an output as the element of the Json object.

Parse an output as a pydantic object.

Parse an output as an attribute of a pydantic object.

Translate Databricks vector search internal query language elements to

Translate Mongo internal query language elements to valid filters.

Translate Elasticsearch internal query language elements to valid filters.

Logic for converting internal query language elements to valid filters.

Translate Chroma internal query language elements to valid filters.

Translate Qdrant internal query language elements to valid filters.

Translate Langchain filters to Supabase PostgREST filters.

Translate Pinecone internal query language elements to valid filters.

Translate Weaviate internal query language elements to valid filters.

Translate Vectara internal query language elements to valid filters.

Translate DingoDB internal query language elements to valid filters.

Translate MyScale internal query language elements to valid filters.

Translate PGVector internal query language elements to valid filters.

Translate the internal query language elements to valid filters.

Translate OpenSearch internal query domain-specific

Visitor for translating structured queries to Redis filter expressions.

Translate Milvus internal query language elements to valid filters.

Translate StructuredQuery to Tencent VectorDB query.

Translate DeepLake internal query language elements to valid filters.

Translate AstraDB internal query language elements to valid filters.

Fake cross encoder model.

Content handler for CrossEncoder class.

SageMaker Inference CrossEncoder endpoint.

HuggingFace cross encoder models.

Allows a BaseModel to return its fields by string variable indexing.

Choice.

Chat completions.

Choice chunk.

Chat completion chunk.

Chat completion.

Completions.

Chat.

Table used to keep track of when a key was last updated.

A SQL Alchemy based implementation of the record manager.

A MongoDB based implementation of the document manager.

Abstract base class for a record manager.

Select and order examples based on ngram overlap score (sentence_bleu score

Simple in memory docstore in the form of a dict.

Docstore via arbitrary lookup function.

Wikipedia API.

Interface to access to place that stores documents.

Mixin class that supports adding texts.

A ByteStore implementation using Cassandra as the backend.

BaseStore implementation using MongoDB as the underlying store.

BaseStore implementation using MongoDB as the underlying store.

BaseStore implementation using Upstash Redis

Table used to save values.

BaseStore interface that works on an SQL database.

BaseStore implementation using Redis as the underlying store.

Base class for the DataStax AstraDB data store.

Import the fiddler python package and raise an error if it is not installed.

Get default Label Studio configs for the given mode.

Import flytekit and flytekitplugins-deck-standard.

Analyze text using textstat and spacy.

Import the getcontext package.

Import the spacy python package and raise an error if it is not installed.

Import the pandas python package and raise an error if it is not installed.

Import the textstat python package and raise an error if it is not installed.

Flatten a nested dictionary into a flat dictionary.

Hash a string using sha1.

Load json file to a string.

Import the mlflow python package and raise an error if it is not installed.

Get the metrics to log to MLFlow.

Get the text complexity metrics from textstat.

Analyze text using textstat and spacy.

Construct an html element from a prompt and a generation.

Standardize the model name to a format that can be used in the OpenAI API.

Get the cost in USD for a given model and number of tokens.

Import the clearml python package and raise an error if it is not installed.

Save dict to local file path.

Import the uptrain package.

Import comet_ml and raise an error if it is not installed.

Import the aim python package and raise an error if it is not installed.

Builds an LLMonitor UserContextManager

Import the infino client.

Import tiktoken for counting tokens for OpenAI models.

Calculate num tokens for OpenAI with tiktoken package.

Get the OpenAI callback handler in a context manager.

Get the Bedrock anthropic callback handler in a context manager.

Get the WandbTracer in a context manager.

Import the wandb python package and raise an error if it is not installed.

Load json file to a dictionary.

Analyze text using textstat and spacy.

Construct an html element from a prompt and a generation.

Import the langkit python package and raise an error if it is not installed.

Callback Handler that writes to a Streamlit app.

Import comet_llm api and raise an error if it is not installed.

Utility to flatten a nest run object into a list of runs.

Utility to truncate a list of runs dictionaries to only keep the specified

Utility to modify the serialized field of a list of runs dictionaries.

Builds a nested dictionary from a list of runs.

Remove a prefix from a text.

Extract Cypher code from a text.

Extract Cypher code from a text.

Extract Gremlin code from a text.

Extract SPARQL code from a text.

Extract Cypher code from a text.

Trim the query to only include Cypher keywords.

Decides whether to use the simple prompt