def METHOD_NAME(self, records, features, threshold=None, file_url=None, predicted_at=None, 
    no_features_in_result=None, score=False, score_true_data=None, predict_labels=None):
    if self.object_id is None:
        raise AugerException('Please provide Auger Pipeline id')
    props = self.properties()
    if not self.check_endpoint(props):
        status = props.get('status')
        if status != 'ready':
            if 'error' in status:
                # there are following options currently:
                # [created_files_with_error, packaged_with_error,
                # deployed_with_error undeployed_with_error]
                error_message = props.get('error_message')
                raise AugerException(
                    """Pipeline %s deployment has failed with following """
                    """error on Auger Cloud: `%s`""" % (
                        self.object_id, error_message))
            else:
                raise AugerException(
                    "Pipeline %s is not ready..." % self.object_id)
    prediction_api = AugerPredictionApi(self.ctx, self, use_endpoint=self.check_endpoint(props))
    prediction_properties = \
        prediction_api.create(records, features, threshold=threshold, file_url=file_url, 
            predicted_at=predicted_at, no_features_in_result=no_features_in_result,
            score=score, score_true_data=score_true_data, predict_labels=predict_labels)
    return prediction_properties.get('result')