def execute(self):
    Executor.wait(EXECUTION_SLEEP)
    force_error = self.execution.get(EXECUTION_MESSAGE_FORCE_ERROR_KEY)
    outputs = Executor.get_outputs(force_error)
    return (force_error, outputs)
def execute(self):
    Executor.wait(EXECUTION_SLEEP)
    force_error = self.execution.get(EXECUTION_MESSAGE_FORCE_ERROR_KEY)
    outputs = Executor.get_outputs(force_error)
    return (force_error, outputs)