def report_failure(exception):
 raise FailedExecution('Exception encountered.  Rerun with loglevel DEBUG and/or check Elasticsearch logs for more information. Exception: {0}'.format(exception))

def report_failure ( exception ) : raise FailedExecution ( 'Exception encountered.  Rerun with loglevel DEBUG and/or check Elasticsearch logs for more information. Exception: {0}' . format ( exception ) )
raise a failedexecution exception and include the original error message .