astra.contrib.ferre.core

Module Contents

Functions

_non_blocking_pipe_read(stream, queue) A non-blocking and non-destructive stream reader for long-running interactive jobs.
class astra.contrib.ferre.core.Ferre(grid_header_path, frozen_parameters=None, interpolation_order=1, init_flag=1, init_algorithm_flag=1, error_algorithm_flag=0, continuum_flag=None, continuum_order=None, continuum_reject=None, continuum_observations_flag=0, optimization_algorithm_flag=3, wavelength_interpolation_flag=0, lsf_shape_flag=0, use_direct_access=True, n_threads=1, directory_kwds=None, input_weights_path=None, input_lsf_path=None, debug=False, ferre_kwds=None, **kwargs)
executable = /uufs/chpc.utah.edu/common/home/sdss09/software/apogee/Linux/apogee/trunk/bin/ferre.x
parameter_names
wavelength
directory
grid_mid_point
grid_limits
n_dimensions
wavelength_mask(self, wavelength)
in_grid_limits(self, points)
parse_initial_parameters(self, initial_parameters, Ns)
fit(self, spectra, initial_parameters=None, full_output=False, names=None, **kwargs)
__call__(self, x, timeout=30)
_write_ferre_input_file(self)

Write a FERRE input file.

_execute(self, bufsize=1, encoding='utf-8', interactive=False, total=None, **kwargs)

Write an input file and execute FERRE.

_check_progress(self, output_flux_path, interval)
_monitor_progress(self, total=None, interval=1, use_tqdm=True, timeout=3600, timeout_cleanup=10, max_wait_time_per_result=60)
get_processing_times(self, stdout=None)

Get the time taken to analyse spectra and estimate the initial load time.

Parameters:stdout – (optional) The standard output from FERRE.
_communicate(self, timeout=None)
_setup(self)
teardown(self)
__enter__(self)
__exit__(self, type, value, traceback)
class astra.contrib.ferre.core.FerreSlurmQueue(grid_header_path, frozen_parameters=None, interpolation_order=1, init_flag=1, init_algorithm_flag=1, error_algorithm_flag=0, continuum_flag=None, continuum_order=None, continuum_reject=None, continuum_observations_flag=0, optimization_algorithm_flag=3, wavelength_interpolation_flag=0, lsf_shape_flag=0, use_direct_access=True, n_threads=1, directory_kwds=None, input_weights_path=None, input_lsf_path=None, debug=False, ferre_kwds=None, **kwargs)
executable = /uufs/chpc.utah.edu/common/home/sdss09/software/apogee/Linux/apogee/trunk/bin/ferre.x
parameter_names
wavelength
directory
grid_mid_point
grid_limits
n_dimensions
_execute(self, bufsize=1, encoding='utf-8', total=None, **kwargs)

Write an input file and execute FERRE, using the Slurm queue submission system.

wavelength_mask(self, wavelength)
in_grid_limits(self, points)
parse_initial_parameters(self, initial_parameters, Ns)
fit(self, spectra, initial_parameters=None, full_output=False, names=None, **kwargs)
__call__(self, x, timeout=30)
_write_ferre_input_file(self)

Write a FERRE input file.

_check_progress(self, output_flux_path, interval)
_monitor_progress(self, total=None, interval=1, use_tqdm=True, timeout=3600, timeout_cleanup=10, max_wait_time_per_result=60)
get_processing_times(self, stdout=None)

Get the time taken to analyse spectra and estimate the initial load time.

Parameters:stdout – (optional) The standard output from FERRE.
_communicate(self, timeout=None)
_setup(self)
teardown(self)
__enter__(self)
__exit__(self, type, value, traceback)
astra.contrib.ferre.core._non_blocking_pipe_read(stream, queue)

A non-blocking and non-destructive stream reader for long-running interactive jobs.

Parameters:
  • stream – The stream to read (e.g., process.stderr).
  • queue – The multiprocessing queue to put the output from the stream to.
astra.contrib.ferre.core.spectrum