Index

_

__init__() (agi_cluster.agi_distributor.agi_distributor.AGI method) (agi_env.agi_env.AgiEnv method) (agi_env.agi_env.ContentRenamer method) (agi_node.agi_dispatcher.base_worker.ArgsNamespace method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight.flight_args.FlightArgs method) (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgs method) (mycode.app_args.MycodeArgsTD method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method)

A

active() (agi_env.agi_env.AgiEnv method) AGI (class in agi_cluster.agi_distributor.agi_distributor) agi_cluster.agi_distributor.agi_distributor module agi_env.agi_env module agi_node.agi_dispatcher.base_worker module agi_node.dag_worker.dag_worker module agi_node.pandas_worker.pandas_worker module agi_node.polars_worker.polars_worker module AgiEnv (class in agi_env.agi_env) agilab module agilab.lab_run module app (agi_env.agi_env.AgiEnv attribute) apply_source_defaults() (in module flight.flight_args) apps_path (agi_env.agi_env.AgiEnv attribute) args (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) args_dump_mode (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) args_dumper (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute)

args_ensure_defaults (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) args_loader (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) args_merger (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) ArgsModel (in module flight.flight_args) (in module mycode.app_args) ArgsNamespace (class in agi_node.agi_dispatcher.base_worker) ArgsOverrides (in module flight.flight_args) (in module mycode.app_args) as_dict() (agi_node.agi_dispatcher.base_worker.BaseWorker method) (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method)

B

BaseWorker (class in agi_node.agi_dispatcher.base_worker) benchmark (agi_env.agi_env.AgiEnv attribute) break() (agi_node.agi_dispatcher.base_worker.BaseWorker method) (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method) break_loop() (agi_node.agi_dispatcher.base_worker.BaseWorker static method) (agi_node.dag_worker.dag_worker.DagWorker static method) (agi_node.pandas_worker.pandas_worker.PandasWorker static method) (agi_node.polars_worker.polars_worker.PolarsWorker static method) (flight.flight.Flight static method) (flight.flight.FlightApp static method) (flight_worker.flight_worker.FlightWorker static method) (mycode.mycode.Mycode static method) (mycode.mycode.MycodeApp static method) (mycode_worker.mycode_worker.MycodeWorker static method)

build_distribution() (flight.flight.Flight method) (flight.flight.FlightApp method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method)

C

calculate_speed() (flight_worker.flight_worker.FlightWorker method) change_app() (agi_env.agi_env.AgiEnv method) check_internet() (agi_env.agi_env.AgiEnv static method) clear() (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method) clone_directory() (agi_env.agi_env.AgiEnv method) clone_project() (agi_env.agi_env.AgiEnv method) construct() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) ContentRenamer (class in agi_env.agi_env)

copy() (flight.flight_args.FlightArgs method) (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgs method) (mycode.app_args.MycodeArgsTD method) copy_existing_projects() (agi_env.agi_env.AgiEnv method) create_junction_windows() (agi_env.agi_env.AgiEnv static method) create_rename_map() (agi_env.agi_env.AgiEnv method) create_symlink() (agi_env.agi_env.AgiEnv static method) create_symlink_windows() (agi_env.agi_env.AgiEnv static method) current() (agi_env.agi_env.AgiEnv class method) CYTHON_MODE (agi_cluster.agi_distributor.agi_distributor.AGI attribute)

D

DagWorker (class in agi_node.dag_worker.dag_worker) DASK_MODE (agi_cluster.agi_distributor.agi_distributor.AGI attribute) data_in (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) (mycode.app_args.MycodeArgs attribute) (mycode.app_args.MycodeArgsTD attribute) data_out (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) (mycode.app_args.MycodeArgs attribute) (mycode.app_args.MycodeArgsTD attribute) data_source (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) datemax (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) datemin (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) debug (agi_cluster.agi_distributor.agi_distributor.AGI attribute) (agi_env.agi_env.AgiEnv attribute) default_settings_path (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute)

default_settings_section (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) dict() (flight.flight_args.FlightArgs method) (mycode.app_args.MycodeArgs method) distribute() (agi_cluster.agi_distributor.agi_distributor.AGI static method) dump_args() (in module flight.flight_args) (in module mycode.app_args) dump_args_to_toml() (in module flight.flight_args)

E

ensure_defaults() (in module flight.flight_args) (in module mycode.app_args) env (agi_cluster.agi_distributor.agi_distributor.AGI attribute) (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) envars (agi_env.agi_env.AgiEnv attribute) err_log (agi_env.agi_env.AgiEnv attribute) exec_ssh() (agi_cluster.agi_distributor.agi_distributor.AGI static method) exec_ssh_async() (agi_cluster.agi_distributor.agi_distributor.AGI static method) expand() (agi_node.agi_dispatcher.base_worker.BaseWorker static method) (agi_node.dag_worker.dag_worker.DagWorker static method) (agi_node.pandas_worker.pandas_worker.PandasWorker static method) (agi_node.polars_worker.polars_worker.PolarsWorker static method) (flight.flight.Flight static method) (flight.flight.FlightApp static method) (flight_worker.flight_worker.FlightWorker static method) (mycode.mycode.Mycode static method) (mycode.mycode.MycodeApp static method) (mycode_worker.mycode_worker.MycodeWorker static method)

expand_and_join() (agi_node.agi_dispatcher.base_worker.BaseWorker static method) (agi_node.dag_worker.dag_worker.DagWorker static method) (agi_node.pandas_worker.pandas_worker.PandasWorker static method) (agi_node.polars_worker.polars_worker.PolarsWorker static method) (flight.flight.Flight static method) (flight.flight.FlightApp static method) (flight_worker.flight_worker.FlightWorker static method) (mycode.mycode.Mycode static method) (mycode.mycode.MycodeApp static method) (mycode_worker.mycode_worker.MycodeWorker static method) EXTRA_INDEX_URL (agi_env.agi_env.AgiEnv attribute) extract_base_info() (agi_env.agi_env.AgiEnv method) extract_plane_from_file_name() (flight.flight.Flight static method) (flight.flight.FlightApp static method)

F

files (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) (mycode.app_args.MycodeArgs attribute) (mycode.app_args.MycodeArgsTD attribute) find_free_port() (agi_cluster.agi_distributor.agi_distributor.AGI static method) Flight (class in flight.flight) flight.flight module flight.flight_args module flight_worker.flight_worker module FlightApp (class in flight.flight) FlightArgs (class in flight.flight_args) FlightArgsTD (class in flight.flight_args)

FlightWorker (class in flight_worker.flight_worker) from_orm() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) from_toml() (agi_node.agi_dispatcher.base_worker.BaseWorker class method) (agi_node.dag_worker.dag_worker.DagWorker class method) (agi_node.pandas_worker.pandas_worker.PandasWorker class method) (agi_node.polars_worker.polars_worker.PolarsWorker class method) (flight.flight.Flight class method) (flight.flight.FlightApp class method) (flight_worker.flight_worker.FlightWorker class method) (mycode.mycode.Mycode class method) (mycode.mycode.MycodeApp class method) (mycode_worker.mycode_worker.MycodeWorker class method) fromkeys() (flight.flight_args.FlightArgsTD class method) (mycode.app_args.MycodeArgsTD class method)

G

generic_visit() (agi_env.agi_env.ContentRenamer method) get() (agi_node.agi_dispatcher.base_worker.ArgsNamespace method) (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method) get_base_classes() (agi_env.agi_env.AgiEnv method) get_base_worker_cls() (agi_env.agi_env.AgiEnv method) get_data_from_files() (flight.flight.Flight method) (flight.flight.FlightApp method) get_data_from_hawk() (flight.flight.Flight method) (flight.flight.FlightApp method)

get_default_local_ip() (agi_cluster.agi_distributor.agi_distributor.AGI static method) get_distrib() (agi_cluster.agi_distributor.agi_distributor.AGI static method) get_full_attribute_name() (agi_env.agi_env.AgiEnv method) get_import_mapping() (agi_env.agi_env.AgiEnv method) get_partition_by_planes() (flight.flight.Flight method) (flight.flight.FlightApp method) get_projects() (agi_env.agi_env.AgiEnv method) get_ssh_connection() (agi_cluster.agi_distributor.agi_distributor.AGI method) get_work() (agi_node.dag_worker.dag_worker.DagWorker method) GUI_SAMPLING (agi_env.agi_env.AgiEnv attribute)

H

has_admin_rights() (agi_env.agi_env.AgiEnv static method) has_agilab_anywhere_under_home() (agi_env.agi_env.AgiEnv method)

humanize_validation_errors() (agi_env.agi_env.AgiEnv method) hw_rapids_capable (agi_env.agi_env.AgiEnv attribute)

I

INDEX_URL (agi_env.agi_env.AgiEnv attribute) init_done (agi_env.agi_env.AgiEnv attribute) init_envars_app() (agi_env.agi_env.AgiEnv method) install() (agi_cluster.agi_distributor.agi_distributor.AGI static method) install_type (agi_env.agi_env.AgiEnv attribute) is_local() (agi_env.agi_env.AgiEnv static method) is_local_worker (agi_env.agi_env.AgiEnv attribute)

is_packaging_cmd() (in module agi_env.agi_env) is_source_env (agi_env.agi_env.AgiEnv attribute) is_valid_ip() (agi_env.agi_env.AgiEnv method) is_worker_env (agi_env.agi_env.AgiEnv attribute) items() (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method) ivq_logs (flight.flight.Flight attribute) (flight.flight.FlightApp attribute)

J

json() (flight.flight_args.FlightArgs method) (mycode.app_args.MycodeArgs method)

K

keys() (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method)

L

load_args() (in module flight.flight_args) (in module mycode.app_args) load_args_from_toml() (in module flight.flight_args) locate_agi_installation() (agi_env.agi_env.AgiEnv static method) locate_agilab_installation() (agi_env.agi_env.AgiEnv static method) log_info() (agi_env.agi_env.AgiEnv static method) logger (agi_env.agi_env.AgiEnv attribute) loop() (agi_node.agi_dispatcher.base_worker.BaseWorker static method) (agi_node.dag_worker.dag_worker.DagWorker static method) (agi_node.pandas_worker.pandas_worker.PandasWorker static method) (agi_node.polars_worker.polars_worker.PolarsWorker static method) (flight.flight.Flight static method) (flight.flight.FlightApp static method) (flight_worker.flight_worker.FlightWorker static method) (mycode.mycode.Mycode static method) (mycode.mycode.MycodeApp static method) (mycode_worker.mycode_worker.MycodeWorker static method)

M

main() (in module agilab.lab_run) managed_pc_home_suffix (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) managed_pc_path_fields (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute) merge_args() (in module flight.flight_args) (in module mycode.app_args) mode2int() (agi_env.agi_env.AgiEnv static method) mode2str() (agi_env.agi_env.AgiEnv method) model_computed_fields (flight.flight_args.FlightArgs attribute) (mycode.app_args.MycodeArgs attribute) model_config (flight.flight_args.FlightArgs attribute) (mycode.app_args.MycodeArgs attribute) model_construct() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) model_copy() (flight.flight_args.FlightArgs method) (mycode.app_args.MycodeArgs method) model_dump() (flight.flight_args.FlightArgs method) (mycode.app_args.MycodeArgs method) model_dump_json() (flight.flight_args.FlightArgs method) (mycode.app_args.MycodeArgs method) model_extra (flight.flight_args.FlightArgs property) (mycode.app_args.MycodeArgs property) model_fields (flight.flight_args.FlightArgs attribute) (mycode.app_args.MycodeArgs attribute)

model_fields_set (flight.flight_args.FlightArgs property) (mycode.app_args.MycodeArgs property) model_json_schema() (mycode.app_args.MycodeArgs class method) model_parametrized_name() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) model_post_init() (flight.flight_args.FlightArgs method) (mycode.app_args.MycodeArgs method) model_rebuild() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) model_validate() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) model_validate_json() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) model_validate_strings() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) module agi_cluster.agi_distributor.agi_distributor agi_env.agi_env agi_node.agi_dispatcher.base_worker agi_node.dag_worker.dag_worker agi_node.pandas_worker.pandas_worker agi_node.polars_worker.polars_worker agilab agilab.lab_run flight.flight flight.flight_args flight_worker.flight_worker mycode.app_args mycode.mycode mycode_worker.mycode_worker Mycode (class in mycode.mycode) mycode.app_args module mycode.mycode module mycode_worker.mycode_worker module MycodeApp (class in mycode.mycode) MycodeArgs (class in mycode.app_args) MycodeArgsTD (class in mycode.app_args) MycodeWorker (class in mycode_worker.mycode_worker)

N

nfile (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) (mycode.app_args.MycodeArgs attribute) (mycode.app_args.MycodeArgsTD attribute) normalize_dataset_path() (agi_node.agi_dispatcher.base_worker.BaseWorker static method) (agi_node.dag_worker.dag_worker.DagWorker static method) (agi_node.pandas_worker.pandas_worker.PandasWorker static method) (agi_node.polars_worker.polars_worker.PolarsWorker static method) (flight.flight.Flight static method) (flight.flight.FlightApp static method) (flight_worker.flight_worker.FlightWorker static method) (mycode.mycode.Mycode static method) (mycode.mycode.MycodeApp static method) (mycode_worker.mycode_worker.MycodeWorker static method)

normalize_path() (in module agi_env.agi_env) nread (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) (mycode.app_args.MycodeArgs attribute) (mycode.app_args.MycodeArgsTD attribute) nskip (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) (mycode.app_args.MycodeArgs attribute) (mycode.app_args.MycodeArgsTD attribute)

O

out_log (agi_env.agi_env.AgiEnv attribute)

output_format (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute)

P

PandasWorker (class in agi_node.pandas_worker.pandas_worker) parse_file() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) parse_level() (in module agi_env.agi_env) parse_obj() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) parse_raw() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) PolarsWorker (class in agi_node.polars_worker.polars_worker) pool_init() (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode static method) (mycode.mycode.MycodeApp static method) pool_vars (flight_worker.flight_worker.FlightWorker attribute) pop() (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method)

popitem() (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method) prepare_output_dir() (agi_node.agi_dispatcher.base_worker.BaseWorker method) (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method) preprocess_df() (flight_worker.flight_worker.FlightWorker method) PYTHON_MODE (agi_cluster.agi_distributor.agi_distributor.AGI attribute) pyvers_worker (agi_env.agi_env.AgiEnv attribute)

R

RAPIDS_MODE (agi_cluster.agi_distributor.agi_distributor.AGI attribute) read_agilab_path() (agi_env.agi_env.AgiEnv static method) read_gitignore() (agi_env.agi_env.AgiEnv method) replace_content() (agi_env.agi_env.AgiEnv method) reset() (agi_env.agi_env.AgiEnv class method) reset_target (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) (mycode.app_args.MycodeArgs attribute) (mycode.app_args.MycodeArgsTD attribute) resolve_input_folder() (agi_node.agi_dispatcher.base_worker.BaseWorker class method) (agi_node.dag_worker.dag_worker.DagWorker class method) (agi_node.pandas_worker.pandas_worker.PandasWorker class method) (agi_node.polars_worker.polars_worker.PolarsWorker class method) (flight.flight.Flight class method) (flight.flight.FlightApp class method) (flight_worker.flight_worker.FlightWorker class method) (mycode.mycode.Mycode class method) (mycode.mycode.MycodeApp class method) (mycode_worker.mycode_worker.MycodeWorker class method)

resolve_share_path() (agi_env.agi_env.AgiEnv method) resources_path (agi_env.agi_env.AgiEnv attribute) run() (agi_cluster.agi_distributor.agi_distributor.AGI static method) (agi_env.agi_env.AgiEnv static method) run_agi() (agi_env.agi_env.AgiEnv method) run_async() (agi_env.agi_env.AgiEnv static method)

S

sampling_rate (flight.flight_args.FlightArgs attribute) (flight.flight_args.FlightArgsTD attribute) schema() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) schema_json() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) send_file() (agi_cluster.agi_distributor.agi_distributor.AGI static method) send_files() (agi_cluster.agi_distributor.agi_distributor.AGI static method) serve() (agi_cluster.agi_distributor.agi_distributor.AGI static method) set_env_var() (agi_env.agi_env.AgiEnv static method) setdefault() (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method) setup_args() (agi_node.agi_dispatcher.base_worker.BaseWorker method) (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method) setup_data_directories() (agi_node.agi_dispatcher.base_worker.BaseWorker method) (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method)

share_root_path() (agi_env.agi_env.AgiEnv method) skip_repo_links (agi_env.agi_env.AgiEnv attribute) snippet_tail (agi_env.agi_env.AgiEnv attribute) start() (agi_node.agi_dispatcher.base_worker.BaseWorker static method) (agi_node.dag_worker.dag_worker.DagWorker static method) (agi_node.pandas_worker.pandas_worker.PandasWorker static method) (agi_node.polars_worker.polars_worker.PolarsWorker static method) (flight.flight.Flight static method) (flight.flight.FlightApp static method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode static method) (mycode.mycode.MycodeApp static method) (mycode_worker.mycode_worker.MycodeWorker static method) stop() (agi_node.agi_dispatcher.base_worker.BaseWorker method) (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method) strip_time_level_prefix() (in module agi_env.agi_env) submit() (agi_cluster.agi_distributor.agi_distributor.AGI static method)

T

TABLE_MAX_ROWS (agi_env.agi_env.AgiEnv attribute) target (agi_env.agi_env.AgiEnv attribute) to_dict() (agi_node.agi_dispatcher.base_worker.ArgsNamespace method) to_toml() (agi_node.agi_dispatcher.base_worker.BaseWorker method) (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight.flight.Flight method) (flight.flight.FlightApp method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method)

to_toml_payload() (flight.flight_args.FlightArgs method)

U

unzip_data() (agi_env.agi_env.AgiEnv method) update() (agi_cluster.agi_distributor.agi_distributor.AGI static method) (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method)

update_forward_refs() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) uv (agi_env.agi_env.AgiEnv attribute)

V

validate() (flight.flight_args.FlightArgs class method) (mycode.app_args.MycodeArgs class method) values() (flight.flight_args.FlightArgsTD method) (mycode.app_args.MycodeArgsTD method) verbose (agi_cluster.agi_distributor.agi_distributor.AGI attribute) (agi_env.agi_env.AgiEnv attribute) (agi_node.agi_dispatcher.base_worker.BaseWorker attribute) (agi_node.dag_worker.dag_worker.DagWorker attribute) (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) (flight.flight.Flight attribute) (flight.flight.FlightApp attribute) (flight_worker.flight_worker.FlightWorker attribute) (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) (mycode_worker.mycode_worker.MycodeWorker attribute)

visit() (agi_env.agi_env.ContentRenamer method) visit_AnnAssign() (agi_env.agi_env.ContentRenamer method) visit_arg() (agi_env.agi_env.ContentRenamer method) visit_Assign() (agi_env.agi_env.ContentRenamer method) visit_Attribute() (agi_env.agi_env.ContentRenamer method) visit_ClassDef() (agi_env.agi_env.ContentRenamer method) visit_Constant() (agi_env.agi_env.ContentRenamer method) visit_For() (agi_env.agi_env.ContentRenamer method) visit_FunctionDef() (agi_env.agi_env.ContentRenamer method) visit_Global() (agi_env.agi_env.ContentRenamer method) visit_Import() (agi_env.agi_env.ContentRenamer method) visit_ImportFrom() (agi_env.agi_env.ContentRenamer method) visit_Name() (agi_env.agi_env.ContentRenamer method) visit_nonlocal() (agi_env.agi_env.ContentRenamer method)

W

work_done() (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method) work_init() (flight_worker.flight_worker.FlightWorker method) work_pool() (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight_worker.flight_worker.FlightWorker method) (mycode.mycode.Mycode method) (mycode.mycode.MycodeApp method) (mycode_worker.mycode_worker.MycodeWorker method)

worker_id (agi_node.pandas_worker.pandas_worker.PandasWorker attribute) (agi_node.polars_worker.polars_worker.PolarsWorker attribute) worker_vars (mycode.mycode.Mycode attribute) (mycode.mycode.MycodeApp attribute) works() (agi_node.dag_worker.dag_worker.DagWorker method) (agi_node.pandas_worker.pandas_worker.PandasWorker method) (agi_node.polars_worker.polars_worker.PolarsWorker method) (flight_worker.flight_worker.FlightWorker method) (mycode_worker.mycode_worker.MycodeWorker method)