tlpipe.timestream.rt2ts.Rt2ts.embarrassingly_parallelizable¶
-
Rt2ts.
embarrassingly_parallelizable
¶ Override to return True if next() is trivially parallelizeable.
This property tells the pipeline that the problem can be parallelized trivially. This only applies to the next() method, which should not change the state of the task.
If this returns True, then the Pipeline will execute next() many times in parallel and handle all the intermediate data efficiently. Otherwise next() must be parallelized internally if at all. setup() and finish() must always be parallelized internally.
Usage of this has not implemented.