1 2 3 4 5 6 7 8 9 10 11 12
from abstract_ra_processor import AbstractRAProcessor class SampleRAProcessorFunction(AbstractRAProcessor): def process(self, execution_request): print "Processing calling.." return None def recover(self, runtime_exception, execution_request): print "Recovering calling.." return None