tlpipe.timestream.barrier.Barrier

class tlpipe.timestream.barrier.Barrier(parameter_file_or_dict=None, feedback=2)[source]

Barrier the iterative pipeline flow before executing its following tasks.

This inherits from DoNothing just for convenient use.

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.
params_init
prefix
__init__(parameter_file_or_dict=None, feedback=2)[source]

Methods

finish()
next(input)
setup()
show_params() Show all parameters that can be set and their default values of this task.