Index

A

AbstractDataset (class in aiflows.datasets.abstract) add_handler() (in module aiflows.utils.logging) 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.composite 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_verse module aiflows.flow_verse.loading module aiflows.flow_verse.utils 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.coflows_utils module aiflows.utils.colink_utils module aiflows.utils.constants module aiflows.utils.general_helpers module aiflows.utils.io_utils module aiflows.utils.logging module aiflows.utils.rich_utils module aiflows.utils.serving module aiflows.workers module aiflows.workers.dispatch_worker module aiflows.workers.get_instance_worker 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)

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) cl (aiflows.base_flows.abstract.Flow attribute) clear_cache() (in module aiflows.flow_cache.flow_cache) coflows_deserialize() (in module aiflows.utils.io_utils)

coflows_serialize() (in module aiflows.utils.io_utils) 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_flow() (in module aiflows.workers.dispatch_worker) 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) created_by (aiflows.messages.abstract.Message attribute)

D

data (aiflows.messages.abstract.Message attribute) DataTransformation (class in aiflows.data_transformations.abstract) delete_all_flow_endpoints() (in module aiflows.utils.serving) delete_entries_on_path() (in module aiflows.utils.colink_utils) delete_flow_endpoint() (in module aiflows.utils.serving) delete_flow_instance() (in module aiflows.utils.serving)

deserialize() (aiflows.messages.abstract.Message class method) disable_default_handler() (in module aiflows.utils.logging) disable_propagation() (in module aiflows.utils.logging) dispatch_response() (in module aiflows.utils.coflows_utils) dispatch_task_handler() (in module aiflows.workers.dispatch_worker) 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)

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) flow_state (aiflows.base_flows.abstract.Flow attribute)

FlowCache (class in aiflows.flow_cache.flow_cache) FlowFuture (class in aiflows.utils.coflows_utils) FlowInstanceException FlowMessage (class in aiflows.messages.flow_message) 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_data() (aiflows.utils.coflows_utils.FlowFuture method) get_flow_instance() (in module aiflows.utils.serving) get_flow_state() (aiflows.base_flows.abstract.Flow method) get_instance_id() (aiflows.base_flows.abstract.Flow method) get_instances_initiator_handler() (in module aiflows.workers.get_instance_worker) get_instances_receiver_handler() (in module aiflows.workers.get_instance_worker) get_interface_description() (aiflows.base_flows.abstract.Flow method)

get_key() (aiflows.backends.llm_lite.LiteLLMBackend 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_message() (aiflows.utils.coflows_utils.FlowFuture method) 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) get_predictions_dir_path() (in module aiflows.utils.general_helpers) get_reply() (aiflows.base_flows.abstract.Flow method) get_reply_future() (aiflows.base_flows.abstract.Flow method) get_verbosity() (in module aiflows.utils.logging)

H

hash_string() (aiflows.flow_cache.flow_cache.CachingKey method)

history_messages_created (aiflows.flow_cache.flow_cache.CachingValue attribute)

I

input_data (aiflows.flow_cache.flow_cache.CachingKey attribute) 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_flow_served() (in module aiflows.utils.serving) 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

LiteLLMBackend (class in aiflows.backends.llm_lite) load_pickle() (in module aiflows.utils.io_utils)

local_proxy_invocations (aiflows.base_flows.abstract.Flow attribute) 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) message_type (aiflows.messages.abstract.Message 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.composite 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_verse aiflows.flow_verse.loading aiflows.flow_verse.utils 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.coflows_utils aiflows.utils.colink_utils aiflows.utils.constants aiflows.utils.general_helpers aiflows.utils.io_utils aiflows.utils.logging aiflows.utils.rich_utils aiflows.utils.serving aiflows.workers aiflows.workers.dispatch_worker aiflows.workers.get_instance_worker

mount() (in module aiflows.utils.serving)

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_results (aiflows.flow_cache.flow_cache.CachingValue attribute) OutputsDataset (class in aiflows.datasets.outputs)

P

package_input_message() (aiflows.base_flows.abstract.Flow method) package_output_message() (aiflows.base_flows.abstract.Flow method) parse_args() (in module aiflows.workers.dispatch_worker) (in module aiflows.workers.get_instance_worker) partial() (aiflows.prompt_template.jinja2_prompts.JinjaPrompt method) pop() (aiflows.flow_cache.flow_cache.FlowCache method)

print_config_tree() (in module aiflows.utils.rich_utils) print_flow_instances() (in module aiflows.utils.colink_utils) print_served_flows() (in module aiflows.utils.colink_utils) PrintPreviousMessages (class in aiflows.data_transformations.print_previous_messages) private_keys (aiflows.messages.abstract.Message attribute) process_config_leafs() (in module aiflows.utils.general_helpers) push_to_flow() (in module aiflows.utils.coflows_utils)

Q

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

quick_load_api_keys() (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_delete_flow_instance() (in module aiflows.utils.serving) recursive_dictionary_update() (in module aiflows.utils.general_helpers) recursive_json_serialize() (in module aiflows.utils.io_utils) recursive_print_keys() (in module aiflows.utils.colink_utils) recursive_serve_flow() (in module aiflows.utils.serving) 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.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) run_dispatch_worker_thread() (in module aiflows.workers.dispatch_worker) run_dispatch_worker_threads() (in module aiflows.workers.dispatch_worker) run_get_instance_worker_thread() (in module aiflows.workers.get_instance_worker)

S

send_message() (aiflows.base_flows.abstract.Flow method) serialize() (aiflows.flow_verse.loading.FlowModuleSpecSummary method) (aiflows.messages.abstract.Message method) serve_flow() (in module aiflows.utils.serving) set() (aiflows.flow_cache.flow_cache.FlowCache method) set_colink() (aiflows.base_flows.abstract.Flow method) set_dir() (in module aiflows.utils.logging) set_output_interface() (aiflows.utils.coflows_utils.FlowFuture method) 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) start_colink_component() (in module aiflows.utils.serving) start_colink_server() (in module aiflows.utils.colink_utils) start_colink_server_with_users() (in module aiflows.utils.colink_utils) subflows (aiflows.base_flows.composite.CompositeFlow 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_string() (aiflows.messages.abstract.Message method) (aiflows.messages.flow_message.FlowMessage 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)

try_except_decorator() (in module aiflows.utils.general_helpers) try_get_data() (aiflows.utils.coflows_utils.FlowFuture method) try_get_message() (aiflows.utils.coflows_utils.FlowFuture method) type() (aiflows.base_flows.abstract.Flow class method) (aiflows.base_flows.atomic.AtomicFlow class method) (aiflows.base_flows.composite.CompositeFlow class method)

U

unflatten_dict() (in module aiflows.utils.general_helpers) UnNesting (class in aiflows.data_transformations.unnesting_dict) unserve_flow() (in module aiflows.utils.serving)

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() (aiflows.backends.api_info.ApiInfo method)

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_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)