Creates and configures an application instance for conducting research. Args: app_id (Optional[str]): A unique identifier for the ap

Builds a graph with :class:`~burr.integrations.bedrock.BedrockAction` (non-streaming).

Builds an application

Runs the application with Burr as the opentelemetry provider

Async version of stream_iterate. Produces an async generator that iterates through intermediate streams. See stream_iterate for more details.

Get the name of all available libraries in the current environment. ref for importlib.metadata: https://docs.python.org/3.11/library/importlib.me

Creates the Burr application

Bootstrap the vector database with some input texts.

Builds the application for synchronous runs. We support both synchronous and asynchronous applications. In case you are using state initializ

This builds the Burr application and returns it. :param starting_image: the starting image to use :param number_of_images_to_caption: the num

Builds the application.

Builds an application with the given parameters. :param app_id: :param graph: :param initial_state: :param initial_entrypoint: :p

Builds the standard application (non-streaming)

Create the Burr `Application`. This is responsible for instantiating the OpenAI client and the LanceDB connection

Builds the graph for the application

Build the UI artifacts from source.

* Chat History * Endpoint to get chat history. Gets the application and returns the chat history from state. * * :param project_id: Project I

* Chat History * Endpoint to get chat history. Gets the application and returns the chat history from state. * * :param project_id: Project I

* Chat Response * Chat response endpoint. User passes in a prompt and the system returns the * full chat history, so its easier to render. *

Pushes state forward for the chatbot. Returns whether or not to rerun the app. :param app_state: State of the app :param prompt: Prompt to se

Check if each file in 'files' exists in 'directory'.

Closes the connection to the database.

Verify everything: signatures, checksums, and licenses.

Handle 'all' subcommand - run complete workflow.

Handle 'archive' subcommand.

Verify licenses with Apache RAT.

List contents of a specific artifact.

Handle 'sdist' subcommand.

Verify signatures and checksums.

Verify wheel metadata with twine.

Handle 'upload' subcommand.

Handle 'verify' subcommand.

Handle 'wheel' subcommand.

Constructs a type based on the arguments passed in. :param kwargs: :return:

Constructs a state based on the arguments passed in. :param kwargs: :return:

Rolling window operation to join consecutive sentences into larger chunks.

* Count * Increment the counter by one step and return the new state. * * :param project_id: Project ID to run * :param app_id: Applicatio

* Create Annotation * @param projectId * @param appId * @param partitionKey * @param sequenceId * @param requestBody * @returns Anno

* Create New Application * @param projectId * @param appId * @returns string Successful Response * @throws ApiError

Creates an annotation by loading all annotations, finding the max ID, and then appending the new annotation. This is not efficient but it's OK

Creates a connection pool that can be shared across persisters.

Helper function to create the table where things are stored.

Helper function to create the table where things are stored if it doesn't exist.

Helper function to create the table where things are stored if it doesn't exist.

Default state and entry point for the application.

Sets the default state & entry point :param query: the query for the agents to work on. :return:

Converts a JSON object to a state delta