Index

A

AbstractDataset (class in aiflows.datasets.abstract) add_handler() (in module aiflows.utils.logging) add_message() (aiflows.history.flow_history.FlowHistory method) add_mod() (aiflows.flow_verse.loading.FlowModuleSpecSummary method) add_to_sys_path() (in module aiflows.flow_verse.loading) aiflows module aiflows.backends module aiflows.backends.api_info module aiflows.backends.llm_lite module aiflows.base_flows module aiflows.base_flows.abstract module aiflows.base_flows.atomic module aiflows.base_flows.branching module aiflows.base_flows.circular module aiflows.base_flows.composite module aiflows.base_flows.sequential module aiflows.data_transformations module aiflows.data_transformations.abstract module aiflows.data_transformations.end_of_interaction module aiflows.data_transformations.json module aiflows.data_transformations.key_copy module aiflows.data_transformations.key_delete module aiflows.data_transformations.key_match_input module aiflows.data_transformations.key_rename module aiflows.data_transformations.key_select module aiflows.data_transformations.key_set module aiflows.data_transformations.print_previous_messages module aiflows.data_transformations.regex_extractor_first module aiflows.data_transformations.unnesting_dict module aiflows.datasets module aiflows.datasets.abstract module

aiflows.datasets.demonstrations_11 module aiflows.datasets.outputs module aiflows.flow_cache module aiflows.flow_cache.flow_cache module aiflows.flow_launchers module aiflows.flow_launchers.abstract module aiflows.flow_launchers.flow_API_launcher module aiflows.flow_verse module aiflows.flow_verse.loading module aiflows.flow_verse.utils module aiflows.history module aiflows.history.flow_history module aiflows.interfaces module aiflows.interfaces.abstract module aiflows.interfaces.key_interface module aiflows.messages module aiflows.messages.abstract module aiflows.messages.flow_message module aiflows.prompt_template module aiflows.prompt_template.jinja2_prompts module aiflows.utils module aiflows.utils.general_helpers module aiflows.utils.io_utils module aiflows.utils.logging module aiflows.utils.rich_utils module api_base (aiflows.backends.api_info.ApiInfo attribute) api_key (aiflows.backends.api_info.ApiInfo attribute) api_version (aiflows.backends.api_info.ApiInfo attribute) ApiInfo (class in aiflows.backends.api_info) AtomicFlow (class in aiflows.base_flows.atomic) auto_set_dir() (in module aiflows.utils.logging)

B

backend_used (aiflows.backends.api_info.ApiInfo attribute) BaseLauncher (class in aiflows.flow_launchers.abstract) BranchingFlow (class in aiflows.base_flows.branching)

build() (aiflows.messages.flow_message.InputMessage static method) build_hf_cache_path() (in module aiflows.flow_verse.utils) build_mod_id() (aiflows.flow_verse.loading.FlowModuleSpec static method)

C

cache_dir (aiflows.flow_cache.flow_cache.CACHING_PARAMETERS attribute) (aiflows.flow_verse.loading.FlowModuleSpec attribute) cache_root (aiflows.flow_verse.loading.FlowModuleSpecSummary property) CACHING_PARAMETERS (class in aiflows.flow_cache.flow_cache) CachingKey (class in aiflows.flow_cache.flow_cache) CachingValue (class in aiflows.flow_cache.flow_cache) CircularFlow (class in aiflows.base_flows.circular) clear_cache() (in module aiflows.flow_cache.flow_cache) commit_hash (aiflows.flow_verse.loading.FlowModuleSpec attribute) CompositeFlow (class in aiflows.base_flows.composite) create_empty_flow_mod_file() (in module aiflows.flow_verse.loading) create_init_py() (in module aiflows.flow_verse.loading) create_unique_id() (in module aiflows.utils.general_helpers)

created_at (aiflows.messages.abstract.Message attribute) (aiflows.messages.flow_message.InputMessage attribute) (aiflows.messages.flow_message.OutputMessage attribute) (aiflows.messages.flow_message.UpdateMessage_ChatMessage attribute) (aiflows.messages.flow_message.UpdateMessage_FullReset attribute) (aiflows.messages.flow_message.UpdateMessage_Generic attribute) (aiflows.messages.flow_message.UpdateMessage_NamespaceReset attribute) created_by (aiflows.messages.abstract.Message attribute) (aiflows.messages.flow_message.InputMessage attribute) (aiflows.messages.flow_message.OutputMessage attribute) (aiflows.messages.flow_message.UpdateMessage_ChatMessage attribute) (aiflows.messages.flow_message.UpdateMessage_FullReset attribute) (aiflows.messages.flow_message.UpdateMessage_Generic attribute) (aiflows.messages.flow_message.UpdateMessage_NamespaceReset attribute)

D

data (aiflows.messages.abstract.Message attribute) (aiflows.messages.flow_message.InputMessage attribute) (aiflows.messages.flow_message.OutputMessage attribute) (aiflows.messages.flow_message.UpdateMessage_ChatMessage attribute) (aiflows.messages.flow_message.UpdateMessage_FullReset attribute) (aiflows.messages.flow_message.UpdateMessage_Generic attribute) (aiflows.messages.flow_message.UpdateMessage_NamespaceReset attribute)

DataTransformation (class in aiflows.data_transformations.abstract) disable_default_handler() (in module aiflows.utils.logging) disable_propagation() (in module aiflows.utils.logging) do_caching (aiflows.flow_cache.flow_cache.CACHING_PARAMETERS attribute)

E

enable_default_handler() (in module aiflows.utils.logging) enable_explicit_format() (in module aiflows.utils.logging) enable_propagation() (in module aiflows.utils.logging) encode_from_buffer() (in module aiflows.utils.general_helpers)

encode_image() (in module aiflows.utils.general_helpers) EndOfInteraction (class in aiflows.data_transformations.end_of_interaction) exception_handler() (in module aiflows.utils.general_helpers) extract_commit_hash_from_cache_mod_dir() (in module aiflows.flow_verse.loading) extract_top_level_function_names() (in module aiflows.utils.general_helpers)

F

fetch_local() (in module aiflows.flow_verse.loading) fetch_remote() (in module aiflows.flow_verse.loading) find_replace_in_dict() (in module aiflows.utils.general_helpers) flatten_dict() (in module aiflows.utils.general_helpers) flow (aiflows.flow_cache.flow_cache.CachingKey attribute) Flow (class in aiflows.base_flows.abstract) flow_config (aiflows.base_flows.abstract.Flow attribute) (aiflows.base_flows.atomic.AtomicFlow attribute) (aiflows.base_flows.sequential.SequentialFlow attribute) flow_state (aiflows.base_flows.abstract.Flow attribute) (aiflows.base_flows.atomic.AtomicFlow attribute) (aiflows.base_flows.sequential.SequentialFlow attribute)

FlowCache (class in aiflows.flow_cache.flow_cache) FlowHistory (class in aiflows.history.flow_history) FlowLauncher (class in aiflows.flow_launchers.flow_API_launcher) FlowModuleSpec (class in aiflows.flow_verse.loading) FlowModuleSpecSummary (class in aiflows.flow_verse.loading) format() (aiflows.prompt_template.jinja2_prompts.JinjaPrompt method) from_flow_mod_file() (aiflows.flow_verse.loading.FlowModuleSpecSummary static method) full_state (aiflows.flow_cache.flow_cache.CachingValue attribute)

G

GenericDemonstrationsDataset (class in aiflows.datasets.demonstrations_11) get() (aiflows.flow_cache.flow_cache.FlowCache method) get_cache_dir() (in module aiflows.flow_cache.flow_cache) get_config() (aiflows.base_flows.abstract.Flow class method) get_current_datetime_ns() (in module aiflows.utils.general_helpers) get_function_from_name() (in module aiflows.utils.general_helpers) get_interface_description() (aiflows.base_flows.abstract.Flow method) get_key() (aiflows.backends.llm_lite.LiteLLMBackend method) get_last_n_messages() (aiflows.history.flow_history.FlowHistory method)

get_log_levels_dict() (in module aiflows.utils.logging) get_logger() (in module aiflows.utils.logging) get_logger_dir() (in module aiflows.utils.logging) get_mod() (aiflows.flow_verse.loading.FlowModuleSpecSummary method) get_mods() (aiflows.flow_verse.loading.FlowModuleSpecSummary method) get_output_data() (aiflows.datasets.outputs.OutputsDataset static method) (aiflows.messages.flow_message.OutputMessage method) get_predictions_dir_path() (in module aiflows.utils.general_helpers) get_verbosity() (in module aiflows.utils.logging)

H

hash_string() (aiflows.flow_cache.flow_cache.CachingKey method) history (aiflows.base_flows.abstract.Flow attribute) (aiflows.base_flows.atomic.AtomicFlow attribute) (aiflows.base_flows.sequential.SequentialFlow attribute)

history_messages_created (aiflows.flow_cache.flow_cache.CachingValue attribute)

I

input_data (aiflows.flow_cache.flow_cache.CachingKey attribute) input_msg_payload_builder() (aiflows.base_flows.circular.CircularFlow static method) InputMessage (class in aiflows.messages.flow_message) instantiate_from_config() (aiflows.base_flows.abstract.Flow class method) (aiflows.base_flows.composite.CompositeFlow class method) instantiate_from_default_config() (aiflows.base_flows.abstract.Flow class method)

instantiate_with_overrides() (aiflows.base_flows.abstract.Flow class method) Interface (class in aiflows.interfaces.abstract) is_local_revision() (in module aiflows.flow_verse.loading) (in module aiflows.flow_verse.utils) is_local_sync_dir_valid() (in module aiflows.flow_verse.loading) is_sync_dir_modified() (in module aiflows.flow_verse.loading)

J

JinjaPrompt (class in aiflows.prompt_template.jinja2_prompts)

Json2Obj (class in aiflows.data_transformations.json)

K

KeyCopy (class in aiflows.data_transformations.key_copy) KeyDelete (class in aiflows.data_transformations.key_delete) KeyInterface (class in aiflows.interfaces.key_interface) KeyMatchInput (class in aiflows.data_transformations.key_match_input)

KeyRename (class in aiflows.data_transformations.key_rename) keys_to_ignore_for_hash (aiflows.flow_cache.flow_cache.CachingKey attribute) KeySelect (class in aiflows.data_transformations.key_select) KeySet (class in aiflows.data_transformations.key_set)

L

launch() (aiflows.flow_launchers.flow_API_launcher.FlowLauncher class method) LiteLLMBackend (class in aiflows.backends.llm_lite)

load_pickle() (in module aiflows.utils.io_utils) log_suggest_help() (in module aiflows.utils.general_helpers)

M

make_unique_api_info_key() (aiflows.backends.llm_lite.LiteLLMBackend static method) max_cached_entries (aiflows.flow_cache.flow_cache.CACHING_PARAMETERS attribute) merge_delta_to_stream() (in module aiflows.backends.llm_lite) merge_streams() (in module aiflows.backends.llm_lite) Message (class in aiflows.messages.abstract) message_id (aiflows.messages.abstract.Message attribute) (aiflows.messages.flow_message.InputMessage attribute) (aiflows.messages.flow_message.OutputMessage attribute) (aiflows.messages.flow_message.UpdateMessage_ChatMessage attribute) (aiflows.messages.flow_message.UpdateMessage_FullReset attribute) (aiflows.messages.flow_message.UpdateMessage_Generic attribute) (aiflows.messages.flow_message.UpdateMessage_NamespaceReset attribute) message_type (aiflows.messages.abstract.Message attribute) (aiflows.messages.flow_message.InputMessage attribute) (aiflows.messages.flow_message.OutputMessage attribute) (aiflows.messages.flow_message.UpdateMessage_ChatMessage attribute) (aiflows.messages.flow_message.UpdateMessage_FullReset attribute) (aiflows.messages.flow_message.UpdateMessage_Generic attribute) (aiflows.messages.flow_message.UpdateMessage_NamespaceReset attribute) mod_id (aiflows.flow_verse.loading.FlowModuleSpec property) module aiflows aiflows.backends aiflows.backends.api_info aiflows.backends.llm_lite aiflows.base_flows aiflows.base_flows.abstract aiflows.base_flows.atomic aiflows.base_flows.branching aiflows.base_flows.circular aiflows.base_flows.composite aiflows.base_flows.sequential aiflows.data_transformations aiflows.data_transformations.abstract aiflows.data_transformations.end_of_interaction aiflows.data_transformations.json aiflows.data_transformations.key_copy aiflows.data_transformations.key_delete aiflows.data_transformations.key_match_input aiflows.data_transformations.key_rename aiflows.data_transformations.key_select aiflows.data_transformations.key_set aiflows.data_transformations.print_previous_messages aiflows.data_transformations.regex_extractor_first aiflows.data_transformations.unnesting_dict aiflows.datasets aiflows.datasets.abstract aiflows.datasets.demonstrations_11 aiflows.datasets.outputs aiflows.flow_cache aiflows.flow_cache.flow_cache aiflows.flow_launchers aiflows.flow_launchers.abstract aiflows.flow_launchers.flow_API_launcher aiflows.flow_verse aiflows.flow_verse.loading aiflows.flow_verse.utils aiflows.history aiflows.history.flow_history aiflows.interfaces aiflows.interfaces.abstract aiflows.interfaces.key_interface aiflows.messages aiflows.messages.abstract aiflows.messages.flow_message aiflows.prompt_template aiflows.prompt_template.jinja2_prompts aiflows.utils aiflows.utils.general_helpers aiflows.utils.io_utils aiflows.utils.logging aiflows.utils.rich_utils

MultiThreadedAPILauncher (class in aiflows.flow_launchers.abstract)

N

name (aiflows.base_flows.abstract.Flow property) nested_keys_pop() (in module aiflows.utils.general_helpers)

nested_keys_search() (in module aiflows.utils.general_helpers) nested_keys_update() (in module aiflows.utils.general_helpers)

O

Obj2Json (class in aiflows.data_transformations.json) output_msg_payload_processor() (aiflows.base_flows.circular.CircularFlow static method)

output_results (aiflows.flow_cache.flow_cache.CachingValue attribute) OutputMessage (class in aiflows.messages.flow_message) OutputsDataset (class in aiflows.datasets.outputs)

P

partial() (aiflows.prompt_template.jinja2_prompts.JinjaPrompt method) pop() (aiflows.flow_cache.flow_cache.FlowCache method) predict() (aiflows.flow_launchers.abstract.BaseLauncher method) (aiflows.flow_launchers.flow_API_launcher.FlowLauncher method) predict_batch() (aiflows.flow_launchers.flow_API_launcher.FlowLauncher class method) predict_dataloader() (aiflows.flow_launchers.abstract.BaseLauncher method) (aiflows.flow_launchers.abstract.MultiThreadedAPILauncher method) predict_sample() (aiflows.flow_launchers.flow_API_launcher.FlowLauncher static method) print_config_tree() (in module aiflows.utils.rich_utils) PrintPreviousMessages (class in aiflows.data_transformations.print_previous_messages)

private_keys (aiflows.messages.abstract.Message attribute) (aiflows.messages.flow_message.InputMessage attribute) (aiflows.messages.flow_message.OutputMessage attribute) (aiflows.messages.flow_message.UpdateMessage_ChatMessage attribute) (aiflows.messages.flow_message.UpdateMessage_FullReset attribute) (aiflows.messages.flow_message.UpdateMessage_Generic attribute) (aiflows.messages.flow_message.UpdateMessage_NamespaceReset attribute) process_config_leafs() (in module aiflows.utils.general_helpers) python_file_path_to_module_path() (in module aiflows.utils.general_helpers) python_module_path_to_file_path() (in module aiflows.utils.general_helpers)

R

read_gzipped_jsonlines() (in module aiflows.utils.general_helpers) read_jsonlines() (in module aiflows.utils.general_helpers) read_outputs() (in module aiflows.utils.general_helpers) read_yaml_file() (in module aiflows.utils.general_helpers) recursive_dictionary_update() (in module aiflows.utils.general_helpers) recursive_json_serialize() (in module aiflows.utils.io_utils) RegexFirstOccurrenceExtractor (class in aiflows.data_transformations.regex_extractor_first) remove_dir_or_link() (in module aiflows.flow_verse.loading) remove_handler() (in module aiflows.utils.logging) repo_id (aiflows.flow_verse.loading.FlowModuleSpec attribute)

REQUIRED_KEYS_CONFIG (aiflows.base_flows.abstract.Flow attribute) (aiflows.base_flows.circular.CircularFlow attribute) (aiflows.base_flows.composite.CompositeFlow attribute) reset() (aiflows.base_flows.abstract.Flow method) reset_format() (in module aiflows.utils.logging) retrive_commit_hash_from_remote() (in module aiflows.flow_verse.loading) revision (aiflows.flow_verse.loading.FlowModuleSpec attribute) run() (aiflows.base_flows.abstract.Flow method) (aiflows.base_flows.branching.BranchingFlow method) (aiflows.base_flows.circular.CircularFlow method)

S

SequentialFlow (class in aiflows.base_flows.sequential) serialize() (aiflows.flow_verse.loading.FlowModuleSpecSummary method) set() (aiflows.flow_cache.flow_cache.FlowCache method) set_dir() (in module aiflows.utils.logging) set_up_flow_state() (aiflows.base_flows.abstract.Flow method) set_verbosity() (in module aiflows.utils.logging) set_verbosity_debug() (in module aiflows.utils.logging) set_verbosity_error() (in module aiflows.utils.logging) set_verbosity_info() (in module aiflows.utils.logging) set_verbosity_warning() (in module aiflows.utils.logging)

subflows (aiflows.base_flows.branching.BranchingFlow attribute) (aiflows.base_flows.circular.CircularFlow attribute) (aiflows.base_flows.composite.CompositeFlow attribute) (aiflows.base_flows.sequential.SequentialFlow attribute) SUPPORTS_CACHING (aiflows.base_flows.abstract.Flow attribute) sync_dependencies() (in module aiflows.flow_verse.loading) sync_dir (aiflows.flow_verse.loading.FlowModuleSpec attribute) sync_local_dep() (in module aiflows.flow_verse.loading) sync_remote_dep() (in module aiflows.flow_verse.loading) sync_root (aiflows.flow_verse.loading.FlowModuleSpecSummary property)

T

to_dict() (aiflows.messages.abstract.Message method) to_list() (aiflows.history.flow_history.FlowHistory method) to_string() (aiflows.history.flow_history.FlowHistory method) (aiflows.messages.abstract.Message method) (aiflows.messages.flow_message.InputMessage method) (aiflows.messages.flow_message.OutputMessage method) (aiflows.messages.flow_message.UpdateMessage_ChatMessage method) (aiflows.messages.flow_message.UpdateMessage_FullReset method) (aiflows.messages.flow_message.UpdateMessage_Generic method) (aiflows.messages.flow_message.UpdateMessage_NamespaceReset method)

TopologyNode (class in aiflows.base_flows.circular) try_except_decorator() (in module aiflows.utils.general_helpers) type() (aiflows.base_flows.abstract.Flow class method) (aiflows.base_flows.atomic.AtomicFlow class method) (aiflows.base_flows.branching.BranchingFlow class method) (aiflows.base_flows.circular.CircularFlow class method) (aiflows.base_flows.composite.CompositeFlow class method) (aiflows.base_flows.sequential.SequentialFlow class method)

U

unflatten_dict() (in module aiflows.utils.general_helpers) UnNesting (class in aiflows.data_transformations.unnesting_dict) UpdateMessage_ChatMessage (class in aiflows.messages.flow_message)

UpdateMessage_FullReset (class in aiflows.messages.flow_message) UpdateMessage_Generic (class in aiflows.messages.flow_message) UpdateMessage_NamespaceReset (class in aiflows.messages.flow_message)

V

validate_and_augment_dependency() (in module aiflows.flow_verse.loading)

validate_flow_config() (in module aiflows.utils.general_helpers)

W

warning_advice() (in module aiflows.utils.logging) warning_once() (in module aiflows.utils.logging) write_batch_output() (aiflows.flow_launchers.abstract.BaseLauncher class method) write_flow_mod_summary() (in module aiflows.flow_verse.loading)

write_gzipped_jsonlines() (in module aiflows.utils.general_helpers) write_jsonlines() (in module aiflows.utils.general_helpers) write_or_append_gitignore() (in module aiflows.flow_verse.loading) write_outputs() (in module aiflows.utils.general_helpers)