Locking added to the pipeline and individual executors.
Method to cleanup and stop processing of a product if error during execution of processing modules.
Merge remote-tracking branch 'upstream/master'