Creates all tasks that this action will run, given the state/inputs. This produces a generator of SubGraphTasks that will be run in parallel.

Update the state using the results of ``Component.run()``. The output socket name is mapped to the Burr state field name. Values retu

* Update Annotation * @param projectId * @param annotationId * @param requestBody * @returns AnnotationOut Successful Response * @throw

Verify licenses in all tar.gz artifacts using Apache RAT.

Verify all signatures and checksums in artifacts directory.

trace() can wrap any function and uses the tracer to create a span and log attributes. This also (by default) logs the inputs/outputs of a fun

Build UI artifacts (npm build + copy to burr/tracking/server/build). This replicates the logic from burr.cli.__main__.run_build_ui_bash_commands(

Run Apache RAT license checker on artifact.

Create SHA512 checksum for artifact.

Restore burr/examples symlink after wheel build.

Get all input sockets that are connected to other components.

Get all output sockets that are connected to other components.

Helper function to create an application context, in the form of the dependency factories we inject to nodes.

Creates a mapping of action tags to lists of corresponding actions. :param actions: List of Action objects :return: Dictionary mappin

This function would fit a model on data upto a certain date.

This function would forecast the next timestep in the simulation given the model and data.

Pick an available localhost port.

Gives a list of log files so we can update the application

Gives a list of metadata files so we can update the application

Gathers all paths to update in s3 -- we store file pointers in the db for these. This allows us to periodically scan for more files to index.

Generate [VOTE] email template.

Creates and caches an OpenAI client instance. Returns: openai.Client: A cached OpenAI client instance.

Iterate over Haystack Component input sockets and inspect default values. If we expect the value to come from state or it's a bound parameter,

Extract version from pyproject.toml.

Handle a single S3 event notification - index the file immediately. :param s3_key: The S3 object key from the event :param event_time

Instrument a Python library. Instrumentation will be skipped if module is not imported nor found in `sys.modules` Exit early if the instrument

Converts a tool to a langchain tool spec.

List contents of a tar.gz archive.

List contents of a wheel file.

Logs a child relationship. This is special as it does not log to the main log file. Rather it logs within the parent directory. Note this only

Parse a kwarg key into (state_key, operator_symbol, comparison_func, explicit). Supports Django-style lookups: ``key__gte=10`` parses as key

Poll URL until 200 or timeout. Fails fast if server process dies.

Handle burr/examples symlink: replace with real files for wheel.

This function would read and process data from a file.

Remove pre-built UI artifacts to ensure clean build.

Generate an image file for the graphviz object. Use graphviz's `.render()` to produce a dot file or open the image on the OS (i.e., `view` ar

Scans and updates the database for a project. TODO -- break this up into functions :param project: Project to scan/update :p

Map socket names to a single socket name. In Haystack, components communicate via sockets. A socket called "embedding" in one component can b

Gives a stable hash for an application. Given the parent app_id and a child key, this will give a hash that will be stable across runs. :para

Join text from every content block (multi-block replies, tool use + text, etc.).

Helper function to transform a state into a test case. :param state: :param action_name: :param test_name: :return:

This function would update the data with the forecasted timestep.

Validate required tools for the requested command.

Check that input socket names passed by the user match the Component's input sockets

Check that output socket names passed by the user match the Component's output sockets

Verify SHA512 checksum of artifact.

Verify SHA512 checksum of artifact.

Verify artifact exists and has reasonable size.

Verify GPG signature of artifact.

Verify GPG signature of artifact.

Verify tar.gz archive can be read and contains files.

Verify wheel can be read and contains expected structure.

The single action to apply to each state. This can be a function (decorated with `@action`, action object, or subdag). :param state:

Drop the table if it exists, create a new table, add data, and create a Full-Text Search index. Semenaitc Search is enabled by default. So cr

* Answer Questions * Endpoint to answer questions the LLM provides * * :param project_id: ID of the project (used by telemetry tracking/stora