Index A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | R | S | T | U | V | W | X | Z A access_counts (pipefunc.cache.HybridCache property) access_weight (pipefunc.cache.HybridCache attribute) AdaptiveSchedulerDetails (class in pipefunc.map.adaptive_scheduler) add() (pipefunc.Pipeline method) add_axes() (pipefunc.map.MapSpec method) add_derivers() (pipefunc.sweep.Sweep method) add_mapspec_axis() (pipefunc.Pipeline method) all_arg_combinations (pipefunc.Pipeline property) all_output_names (pipefunc.map.RunInfo attribute) (pipefunc.Pipeline property) all_root_args (pipefunc.Pipeline property) allow_cloudpickle (pipefunc.cache.HybridCache attribute) arg_combinations() (pipefunc.Pipeline method) args (pipefunc.ErrorSnapshot attribute) arr (pipefunc.map.xarray.DimensionlessArray attribute) Array (class in pipefunc.typing) ArrayElementType (class in pipefunc.typing) axis (pipefunc.map.adaptive.AxisIndex attribute) AxisIndex (class in pipefunc.map.adaptive) B bound (pipefunc.PipeFunc property) build_mcp_server() (in module pipefunc.mcp) C cache (pipefunc.cache.DiskCache property) (pipefunc.cache.HybridCache property) (pipefunc.cache.LRUCache property) (pipefunc.cache.SimpleCache property) (pipefunc.lazy.TaskGraph attribute) chain() (in module pipefunc.helpers) clear() (pipefunc.cache.DiskCache method) (pipefunc.cache.HybridCache method) (pipefunc.cache.LRUCache method) (pipefunc.cache.SimpleCache method) cli() (pipefunc.Pipeline method) collect_kwargs() (in module pipefunc.helpers) combine() (pipefunc.sweep.MultiSweep method) (pipefunc.sweep.Sweep method) combine_max() (pipefunc.resources.Resources static method) computation_durations (pipefunc.cache.HybridCache property) construct_dag() (in module pipefunc.lazy) copy() (pipefunc.NestedPipeFunc method) (pipefunc.PipeFunc method) (pipefunc.Pipeline method) (pipefunc.VariantPipeline method) cores_per_node (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) count_sweep() (in module pipefunc.sweep) cpus (pipefunc.resources.Resources attribute) cpus_per_node (pipefunc.resources.Resources attribute) create() (pipefunc.map.RunInfo class method) create_learners() (in module pipefunc.map.adaptive) create_learners_from_sweep() (in module pipefunc.map.adaptive) current_directory (pipefunc.ErrorSnapshot attribute) D debug (pipefunc.Pipeline property) defaults (pipefunc.map.RunInfo attribute) (pipefunc.PipeFunc property) (pipefunc.Pipeline property) defaults_path (pipefunc.map.RunInfo property) dependencies (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) dict() (pipefunc.resources.Resources method) DictArray (class in pipefunc.map) DimensionlessArray (class in pipefunc.map.xarray) DiskCache (class in pipefunc.cache) drop() (pipefunc.Pipeline method) dump() (pipefunc.helpers.FileArray method) (pipefunc.map.DictArray method) (pipefunc.map.FileArray method) (pipefunc.map.RunInfo method) (pipefunc.map.StorageBase method) (pipefunc.map.ZarrFileArray method) dump_in_subprocess (pipefunc.helpers.FileArray property) (pipefunc.map.DictArray property) (pipefunc.map.FileArray property) (pipefunc.map.SharedMemoryDictArray property) (pipefunc.map.StorageBase property) (pipefunc.map.ZarrFileArray property) (pipefunc.map.ZarrMemoryArray property) (pipefunc.map.ZarrSharedMemoryArray property) duration_weight (pipefunc.cache.HybridCache attribute) E error_handling (pipefunc.map.RunInfo attribute) error_snapshot (pipefunc.PipeFunc attribute) (pipefunc.Pipeline property) ErrorSnapshot (class in pipefunc) evaluate_lazy() (in module pipefunc.lazy) exception (pipefunc.ErrorSnapshot attribute) executor_type (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) external_indices (pipefunc.map.MapSpec property) extra_args (pipefunc.resources.Resources attribute) extra_scheduler (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) F FileArray (class in pipefunc.helpers) (class in pipefunc.map) FileValue (class in pipefunc.helpers) filtered_sweep() (pipefunc.sweep.MultiSweep method) (pipefunc.sweep.Sweep method) flatten() (pipefunc.map.adaptive.LearnersDict method) fnames (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) from_data() (pipefunc.helpers.FileArray class method) (pipefunc.helpers.FileValue class method) (pipefunc.map.FileArray class method) from_dict() (pipefunc.resources.Resources static method) from_pipelines() (pipefunc.VariantPipeline class method) from_string() (pipefunc.map.MapSpec class method) full_shape (pipefunc.map.StorageBase property) full_shape_is_resolved() (pipefunc.map.StorageBase method) func (pipefunc.NestedPipeFunc property) func() (pipefunc.Pipeline method) func_dependencies() (pipefunc.Pipeline method) func_dependents() (pipefunc.Pipeline method) function (pipefunc.ErrorSnapshot attribute) G gather_maps() (in module pipefunc.helpers) generate() (pipefunc.sweep.MultiSweep method) (pipefunc.sweep.Sweep method) generate_sweep() (in module pipefunc.sweep) get() (pipefunc.cache.DiskCache method) (pipefunc.cache.HybridCache method) (pipefunc.cache.LRUCache method) (pipefunc.cache.SimpleCache method) get_attribute_factory() (in module pipefunc.helpers) get_from_index() (pipefunc.helpers.FileArray method) (pipefunc.map.DictArray method) (pipefunc.map.FileArray method) (pipefunc.map.StorageBase method) (pipefunc.map.ZarrFileArray method) globals (pipefunc.typing.TypeCheckMemo attribute) gpus (pipefunc.resources.Resources attribute) graph (pipefunc.lazy.TaskGraph attribute) (pipefunc.Pipeline property) H has_index() (pipefunc.helpers.FileArray method) (pipefunc.map.DictArray method) (pipefunc.map.FileArray method) (pipefunc.map.StorageBase method) (pipefunc.map.ZarrFileArray method) HybridCache (class in pipefunc.cache) I idx (pipefunc.map.adaptive.AxisIndex attribute) independent_axes_in_mapspecs() (pipefunc.Pipeline method) info() (pipefunc.Pipeline method) init_store() (pipefunc.map.RunInfo method) input_indices (pipefunc.map.MapSpec property) input_keys() (pipefunc.map.MapSpec method) input_names (pipefunc.map.MapSpec property) input_paths (pipefunc.map.RunInfo property) inputs (pipefunc.map.MapSpec attribute) (pipefunc.map.RunInfo attribute) internal_shape (pipefunc.map.FileArray attribute) (pipefunc.map.StorageBase attribute) internal_shapes (pipefunc.map.RunInfo attribute) ip_address (pipefunc.ErrorSnapshot attribute) is_object_array_type() (in module pipefunc.typing) is_type_compatible() (in module pipefunc.typing) J JobInfo (class in pipefunc.mcp) join() (pipefunc.Pipeline method) K kwargs (pipefunc.ErrorSnapshot attribute) kwargs() (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails method) L launch_maps() (in module pipefunc.helpers) leaf_nodes (pipefunc.Pipeline property) learner (pipefunc.map.adaptive.LearnerPipeFunc attribute) LearnerPipeFunc (class in pipefunc.map.adaptive) learners (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) LearnersDict (class in pipefunc.map.adaptive) list() (pipefunc.sweep.MultiSweep method) (pipefunc.sweep.Sweep method) load() (pipefunc.helpers.FileValue method) (pipefunc.map.DictArray method) (pipefunc.map.RunInfo class method) (pipefunc.map.ZarrMemoryArray method) load_all_outputs() (in module pipefunc.map) load_dataframe() (in module pipefunc.map) load_from_file() (pipefunc.ErrorSnapshot class method) load_outputs() (in module pipefunc.map) load_xarray() (in module pipefunc.map.xarray) load_xarray_dataset() (in module pipefunc.map) (in module pipefunc.map.xarray) locals (pipefunc.typing.TypeCheckMemo attribute) LRUCache (class in pipefunc.cache) M machine (pipefunc.ErrorSnapshot attribute) map() (pipefunc.Pipeline method) map_async() (pipefunc.Pipeline method) mapping (pipefunc.lazy.TaskGraph attribute) MapSpec (class in pipefunc.map) mapspec_axes (pipefunc.Pipeline property) mapspec_dimensions (pipefunc.Pipeline property) mapspec_names (pipefunc.Pipeline property) mapspecs (pipefunc.map.RunInfo property) mapspecs() (pipefunc.Pipeline method) mapspecs_as_strings (pipefunc.map.RunInfo attribute) (pipefunc.Pipeline property) mask (pipefunc.helpers.FileArray property) (pipefunc.map.DictArray property) (pipefunc.map.FileArray property) (pipefunc.map.StorageBase property) (pipefunc.map.ZarrFileArray property) mask_linear() (pipefunc.helpers.FileArray method) (pipefunc.map.DictArray method) (pipefunc.map.FileArray method) (pipefunc.map.StorageBase method) (pipefunc.map.ZarrFileArray method) max_size (pipefunc.cache.HybridCache attribute) maybe_from_dict() (pipefunc.resources.Resources static method) maybe_with_defaults() (pipefunc.resources.Resources static method) memoize() (in module pipefunc.cache) memory (pipefunc.resources.Resources attribute) module pipefunc pipefunc.cache pipefunc.helpers pipefunc.lazy pipefunc.map pipefunc.map.adaptive pipefunc.map.adaptive_scheduler pipefunc.map.xarray pipefunc.mcp pipefunc.resources pipefunc.sweep pipefunc.testing pipefunc.typing MultiSweep (class in pipefunc.sweep) N nest_funcs() (pipefunc.Pipeline method) NestedPipeFunc (class in pipefunc) NoAnnotation (class in pipefunc.typing) node_mapping (pipefunc.Pipeline property) nodes (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) (pipefunc.resources.Resources attribute) O original_parameters (pipefunc.NestedPipeFunc property) (pipefunc.PipeFunc property) output_annotation (pipefunc.NestedPipeFunc property) (pipefunc.PipeFunc property) output_annotations (pipefunc.Pipeline property) output_indices (pipefunc.map.MapSpec property) output_key() (pipefunc.map.MapSpec method) output_name (pipefunc.PipeFunc property) output_names (pipefunc.map.MapSpec property) output_picker (pipefunc.PipeFunc property) output_to_func (pipefunc.Pipeline property) outputs (pipefunc.map.MapSpec attribute) P parallelization_mode (pipefunc.resources.Resources attribute) parameter_annotations (pipefunc.NestedPipeFunc property) (pipefunc.PipeFunc property) (pipefunc.Pipeline property) parameter_scopes (pipefunc.PipeFunc property) parameters (pipefunc.PipeFunc property) partition (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails attribute) (pipefunc.resources.Resources attribute) patch() (in module pipefunc.testing) path() (pipefunc.map.RunInfo static method) persist() (pipefunc.map.DictArray method) (pipefunc.map.StorageBase method) (pipefunc.map.ZarrMemoryArray method) persistent_store (pipefunc.map.ZarrMemoryArray property) pipefunc module PipeFunc (class in pipefunc) pipefunc (pipefunc.map.adaptive.LearnerPipeFunc attribute) pipefunc() (in module pipefunc) pipefunc.cache module pipefunc.helpers module pipefunc.lazy module pipefunc.map module pipefunc.map.adaptive module pipefunc.map.adaptive_scheduler module pipefunc.map.xarray module pipefunc.mcp module pipefunc.resources module pipefunc.sweep module pipefunc.testing module pipefunc.typing module pipefunc_version (pipefunc.map.RunInfo attribute) pipefuncs (pipefunc.NestedPipeFunc attribute) Pipeline (class in pipefunc) pipeline (pipefunc.NestedPipeFunc attribute) pipeline_name (pipefunc.mcp.JobInfo attribute) print_documentation() (pipefunc.Pipeline method) print_error (pipefunc.Pipeline property) print_profiling_stats() (pipefunc.Pipeline method) product() (pipefunc.sweep.Sweep method) profile (pipefunc.PipeFunc property) (pipefunc.Pipeline property) profiling_stats (pipefunc.Pipeline property) put() (pipefunc.cache.DiskCache method) (pipefunc.cache.HybridCache method) (pipefunc.cache.LRUCache method) (pipefunc.cache.SimpleCache method) pydantic_model() (pipefunc.Pipeline method) R rank (pipefunc.map.StorageBase property) (pipefunc.map.ZarrFileArray property) register_storage() (in module pipefunc.map) rename() (pipefunc.map.MapSpec method) rename_axes() (pipefunc.map.MapSpec method) renames (pipefunc.PipeFunc property) replace() (pipefunc.Pipeline method) reproduce() (pipefunc.ErrorSnapshot method) requires_mapping (pipefunc.PipeFunc property) requires_serialization (pipefunc.helpers.FileArray attribute) (pipefunc.map.DictArray attribute) (pipefunc.map.FileArray attribute) (pipefunc.map.SharedMemoryDictArray attribute) (pipefunc.map.StorageBase attribute) (pipefunc.map.ZarrFileArray attribute) (pipefunc.map.ZarrMemoryArray attribute) (pipefunc.map.ZarrSharedMemoryArray attribute) resolve_downstream_shapes() (pipefunc.map.RunInfo method) resolved_internal_shape (pipefunc.map.StorageBase property) resolved_shape (pipefunc.map.StorageBase property) resolved_shapes (pipefunc.map.RunInfo attribute) Resources (class in pipefunc.resources) root_args() (pipefunc.Pipeline method) root_nodes (pipefunc.Pipeline property) run() (pipefunc.Pipeline method) run_folder (pipefunc.map.RunInfo attribute) (pipefunc.mcp.JobInfo attribute) run_manager() (pipefunc.map.adaptive_scheduler.AdaptiveSchedulerDetails method) run_map() (in module pipefunc.map) run_map_async() (in module pipefunc.map) RunInfo (class in pipefunc.map) runner (pipefunc.mcp.JobInfo attribute) S safe_get_type_hints() (in module pipefunc.typing) save_to_file() (pipefunc.ErrorSnapshot method) scopes (pipefunc.Pipeline property) self_type (pipefunc.typing.TypeCheckMemo attribute) set_cache_for_sweep() (in module pipefunc.sweep) shape (pipefunc.map.FileArray attribute) (pipefunc.map.StorageBase attribute) shape() (pipefunc.map.MapSpec method) shape_mask (pipefunc.map.FileArray attribute) (pipefunc.map.StorageBase attribute) shape_masks (pipefunc.map.RunInfo attribute) shapes (pipefunc.map.RunInfo attribute) shared (pipefunc.cache.DiskCache property) (pipefunc.cache.HybridCache attribute) SharedMemoryDictArray (class in pipefunc.map) simple_run() (pipefunc.map.adaptive.LearnersDict method) SimpleCache (class in pipefunc.cache) simplified_pipeline() (pipefunc.Pipeline method) size (pipefunc.map.StorageBase property) (pipefunc.map.ZarrFileArray property) slurm_run_setup() (in module pipefunc.map.adaptive_scheduler) sorted_functions (pipefunc.Pipeline property) split_disconnected() (pipefunc.Pipeline method) started_at (pipefunc.mcp.JobInfo attribute) status (pipefunc.mcp.JobInfo attribute) storage (pipefunc.map.RunInfo attribute) storage_class() (pipefunc.map.RunInfo method) storage_id (pipefunc.helpers.FileArray attribute) (pipefunc.map.DictArray attribute) (pipefunc.map.FileArray attribute) (pipefunc.map.SharedMemoryDictArray attribute) (pipefunc.map.StorageBase attribute) (pipefunc.map.ZarrFileArray attribute) (pipefunc.map.ZarrMemoryArray attribute) (pipefunc.map.ZarrSharedMemoryArray attribute) StorageBase (class in pipefunc.map) strides (pipefunc.map.StorageBase property) subpipeline() (pipefunc.Pipeline method) Sweep (class in pipefunc.sweep) T task_graph() (in module pipefunc.lazy) TaskGraph (class in pipefunc.lazy) time (pipefunc.resources.Resources attribute) timestamp (pipefunc.ErrorSnapshot attribute) to_adaptive_learner() (in module pipefunc.map.adaptive) to_array() (pipefunc.helpers.FileArray method) (pipefunc.map.DictArray method) (pipefunc.map.FileArray method) (pipefunc.map.StorageBase method) (pipefunc.map.ZarrFileArray method) to_hashable() (in module pipefunc.cache) to_slurm_options() (pipefunc.resources.Resources method) to_slurm_run() (pipefunc.map.adaptive.LearnersDict method) to_string() (pipefunc.map.MapSpec method) topological_generations (pipefunc.Pipeline property) traceback (pipefunc.ErrorSnapshot attribute) try_to_hashable() (in module pipefunc.cache) type_as_string() (in module pipefunc.typing) TypeCheckMemo (class in pipefunc.typing) U UnhashableError unique_leaf_node (pipefunc.Pipeline property) Unresolvable (class in pipefunc.typing) unscoped_parameters (pipefunc.PipeFunc property) update() (pipefunc.resources.Resources method) update_bound() (pipefunc.PipeFunc method) update_defaults() (pipefunc.PipeFunc method) (pipefunc.Pipeline method) update_mapspec_axes() (pipefunc.PipeFunc method) (pipefunc.Pipeline method) update_renames() (pipefunc.PipeFunc method) (pipefunc.Pipeline method) update_scope() (pipefunc.PipeFunc method) (pipefunc.Pipeline method) user (pipefunc.ErrorSnapshot attribute) V validate() (pipefunc.Pipeline method) VariantPipeline (class in pipefunc) variants_mapping() (pipefunc.VariantPipeline method) visualize() (pipefunc.Pipeline method) (pipefunc.VariantPipeline method) visualize_graphviz() (pipefunc.Pipeline method) visualize_graphviz_widget() (pipefunc.Pipeline method) visualize_holoviews() (pipefunc.Pipeline method) visualize_matplotlib() (pipefunc.Pipeline method) W with_defaults() (pipefunc.resources.Resources method) with_variant() (pipefunc.VariantPipeline method) X xarray_dataset_from_results() (in module pipefunc.map.xarray) xarray_dataset_to_dataframe() (in module pipefunc.map.xarray) Z ZarrFileArray (class in pipefunc.map) ZarrMemoryArray (class in pipefunc.map) ZarrSharedMemoryArray (class in pipefunc.map)
