Collect all artifacts for upload.

Extracts the inputs and overrides from the state.

Quick tool to get the application -- caches it

Quick tool to get the application -- caches it

Quick tool to get the application -- caches it

Utility to get the application. Depending on your use-case you might want to reload from state every time (or consider cache invalidation)

Query S3 file with buffering to handle large files. BIP-0042: Uses SpooledTemporaryFile to buffer content, spilling to disk if the file excee

This advances the state machine, moving through to the next 'halting' point

Inits the asynchronous with_state_persister to save the state (local/DB/custom implementations). Moved here to be able to chain methods and de

Inits the synchronous with_state_persister to save the state (local/DB/custom implementations). Moved here to mimic the async case.

Performs a state update for an action -- allowing for deletes. This is suboptimal -- we should not be observing the state, we should be using the

Internal-facing version of step. This is the same as step, but with an additional parameter to hide hook execution so async can leverage it.

Calls all the lifecycle hooks in this group, by hook name (stage). :param hook_name: Name of the hook :param kwargs: Keyword argument

Creates the initial action span for an action. This should be only called if the current action span is none. :param action:

Helper function to create the table where things are stored.

Creates a new instance of the RedisBasePersister from passed in values.

* Get Apps * Gets all apps visible by the user * * :param request: FastAPI request * :param project_id: project name * :return: a list

Creates the table

Returns list of app IDs for a given primary key

See docstring for @action.pydantic

Sends a query to the OpenAI API and retrieves the response. Args: system_instructions (str): Instructions for the system message.

Renders the entire explorer, including the state machine, the action, and the state/results. :param app_state: State of the app :return: None

Runs a hamilton action, using the driver to execute the hamilton DAG. :param state: The state to use :return: The results of the hami

Runs the agent with the given input audio (in this case a string transcription...). :param input_audio: we fake it here, and ask for a string...

Helper function to setup logging to console. :param log_level: Log level to use when logging

Streaming action ``stream_run`` is different than standard action run. It: 1. streams in an intermediate result (the dict output) 2. y

Assigns a default executor to be used for recursive/parallel sub-actions. This effectively allows for executing multiple Burr apps in parallel

Build source distribution from git using flit.

Build wheel from current directory (matches what voters do). This is MUCH simpler than the old approach: - No temp directory extraction -

Compact the hash to a string that's safe to pass around.

This is a utility function to create a string representation of a dict. This is the state that was passed into the function usually. This is usefu

Create git archive tar.gz for voting.

Utility to create sub-application -- note

Whether or not a hook is implemented by any of the adapters in this group. If this hook is not registered, this will raise a ValueError.

Given the paths to update, ensure that all corresponding applications exist in the database. :param paths_to_update: :param project:

Helper function to exercise the agent code.

Formats the error string, given that we're inside an action

Utility to get the application. Depending on your use-case you might want to reload from state every time (or consider cache invalidation)

Helper to determine which state to load.

Initializes the state of the application. Either there is a loaded configuration provided or we use the default state to initialize.

Loads from the set async persister and into this current object. Mutates: - self.state - self.sequence_id - maybe

Loads from the set sync persister and into this current object. Mutates: - self.state - self.sequence_id - maybe s