astrohack.utils.graph

Functions

create_and_execute_graph_from_dict(looping_dict, ...)
create_and_execute_graphs_for_outputs(mds_object, ...)	Dask parallelization exclusively for exports, parallelization is done at the antenna level to decrease graph size and optimize plot creation.
compute_graph_from_lists(param_dict, chunk_function, ...)	Creates and executes a graph based on entries in a parameter dictionary that are lists

Module Contents

create_and_execute_graph_from_dict(looping_dict, chunk_function, param_dict, key_order, output_mds=None, fetch_returns=False)

create_and_execute_graphs_for_outputs(mds_object, chunk_function, param_dict, key_order, fetch_returns=False)

Dask parallelization exclusively for exports, parallelization is done at the antenna level to decrease graph size and optimize plot creation. :param mds_object: Astrohack MDS object from which to plot :param chunk_function: Plotting chunk function :param param_dict: The chunk function parameters :param key_order: Order in which to execute keys :param fetch_returns: Return value from chunk function

Returns:

None

compute_graph_from_lists(param_dict, chunk_function, looping_key_list)

Creates and executes a graph based on entries in a parameter dictionary that are lists :param param_dict: The parameter dictionary :param chunk_function: The function for the operation chunk :param looping_key_list: The keys that are lists in the parameter dictionaries over which to loop over

Returns:

A list containing the returns of the calls to the chunk function.