tlpipe.timestream.dispatch.Dispatch

class tlpipe.timestream.dispatch.Dispatch(parameter_file_or_dict=None, feedback=2)

Dispatch data.

This task will (maybe iteratively) load data from the input data files according to the required data selection (time, frequency, baseline selection). If work iteratively, data will be iteratively loaded according to the time unit set in the input pipe file, and the loaded data (contained in a data container which is a RawTimestream object) will be dispatched to other tasks to be further processed.

Note

This usually should be the first task in the input pipe file to select and load the data from input data files for other tasks.

Note

Current this task only works for a continuously observed data sets. Works need to do to make it work also for data observed in dis-continuous time periods.

Attributes

cacheable	Override to return True if caching results is implemented.
embarrassingly_parallelizable	Override to return True if next() is trivially parallelizeable.
history	History that will be added to the output file.
iteration	Current iteration when iterable is True, None else.
params_init
prefix

__init__(parameter_file_or_dict=None, feedback=2)

Methods

cast_input(input)	Override to support accepting pipeline inputs of various types.
copy_input(tod)	Return a copy of tod, so the original tod would not be changed.
data_select(tod)	Data select.
finish()	Final analysis stage of pipeline task.
next([input])	Should not need to override.
process(rt)	Return loaded data as a RawTimestream object.
read_input()	Method for (maybe iteratively) reading data from input data files.
read_output(filenames)	Override to implement reading outputs from disk.
read_process_write(tod)	Reads input, executes any processing and writes output.
restart_iteration()	Re-start the iteration.
setup([requires])	First analysis stage of pipeline task.
show_params()	Show all parameters that can be set and their default values of this task.
stop_iteration([force_stop])	Determine whether to stop the iteration.
subset_select(tod)	Data subset select.
write_output(output)	Method for writing time ordered data output.