Creates a new instance of the SQLitePersister from a configuration dictionary. The config key:value pair needed are: db_path: str,

Builds a new instance of the PostgreSQLPersister from the provided values. :param db_name: the name of the PostgreSQL database. :para

Initializes the MongoDBBasePersister class.

Builds a new instance of the PostgreSQLPersister from the provided values. Can be used with ``await`` or as an async context manager::

Creates a new instance of the AsyncSQLitePersister from passed in values. Can be used with ``await`` or as an async context manager::

* Get Counter State * Get the current counter state without incrementing. * * :param project_id: Project ID * :param app_id: App ID * :

* Get Indexing Jobs * @param offset * @param limit * @param filterEmpty * @returns IndexingJob Successful Response * @throws ApiError

Gets an action object given the action name

Gets the annotation by loading all annotations and filtering by the parameters. Will return all annotations that match. Only project is requir

Lists out all steps for a given app. :param request: The request object, used for authentication/authorization if needed :param app_i

Return a list of directories under the given base_path.

Quick tool to get the latest sequence ID from a log file. This is not efficient and should be replaced.

Returns the source code of the action. This will default to the source code of the class in which the action is implemented, but can b

Return the source code of the Haystack ``Component``. NOTE. This doesn't include the initialization parameters of the ``Component``.

Application graph object -- if you want to inspect, visualize, etc.. this is what you want. :return: The application graph object

This shows how to use the Hamilton syntactic wrapper for the nodes.

Convert the primitive to a string and hash it

Convert a Haystack `Pipeline` to a Burr `Graph`. NOTE. This currently doesn't support Haystack pipelines with parallel branches. Learn more h

Import a module from a file path. :param file_path: file path. Assume it exists. :return:

Instruments the specified libraries, or all that are installed if it is enabled. This will check if any libraries are available in the current en

Creates the table if it doesn't exist

* Initialize Draft * Endpoint to initialize the draft with the email and instructions * * :param project_id: ID of the project (used by telem

Opens a Google Colab port and launches the Burr UI in a subprocess. Using a subprocess ensures that the Burr server logs aren't displayed in

Launch the Burr UI in a subprocess. Using a subprocess ensures that the Burr server logs aren't displayed in Colab cell outputs

Lists the app_ids for a given partition_key.

Lists out all apps (continual state machine runs with shared state) for a given project. :param request: The request object, used for authent

List contents of a specific artifact.

Lists out all projects -- this relies on the paginate function to work properly. :param request: The request object, used for authentication/

Returns a condition that evaluates the given function of State. Note that this is just a simple wrapper over the Condition object. Th

Loads state for a given partition id. Depending on the parameters, this will return the last thing written, the last thing written for a give

Load strings from text files in `burr_docs_dir` and merge short documents. If `file_names` is None, load all files in the directory.

This is deprecated and will be removed when we migrate over demos. Do not use! Instead use the persistence API :py:class:`initialize_from <bur

Load test cases from a json file.

Main entry point.

Main entry point.

Main function to run the application. :param query: the query for the agents to run over. :param app_instance_id: a prior app instance id to

Main function to run the multi-agent collaboration example. Pass in a query to start from a specific query. Pass in an app_instance_id to res

Main function to run the application. :param query: the query for the agents to run over. :param app_instance_id: a prior app instance id to

Main function to run the application. :param query: the query for the agents to run over. :param app_instance_id: a prior app instance id to

Main function to run the application. :param query: the query for the agents to run over. :param app_instance_id: a prior app instance id to

This is one way -- you provide input via the control flow

Experimental API for creating a map-reduce action easily. We'll be improving this.

Merge short documents into longer ones for better performance. `file_name` is the name of the file the documents came from. It's just for met

Mount the Burr UI inside another FastAPI app. :param parent_app: The parent FastAPI application to mount onto. :param path: URL path prefix f

Unique name of this operation for ser/deser

* Provide Feedback * Endpoint to provide feedback to the LLM * * :param project_id: ID of the project (used by telemetry tracking/storage)

See docstring for @streaming_action.pydantic

Renders the current action, including the reads, writes, and the code for the action. With Hamilton actions, it will also show the visualization o