Trait AsyncDataReviewService

pub trait AsyncDataReviewService {
    // Required methods
    fn batch_initiate(
        &self,
        auth_: BearerToken,
        request: BatchInitiateDataReviewRequest,
    ) -> impl Future<Output = Result<BatchInitiateDataReviewResponse, Error>> + Send;
    fn rerun_failed_automatic_checks(
        &self,
        auth_: BearerToken,
        request: RerunFailedAutomaticChecksRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn find_data_reviews(
        &self,
        auth_: BearerToken,
        request: FindDataReviewsRequest,
    ) -> impl Future<Output = Result<DataReviewPage, Error>> + Send;
    fn get(
        &self,
        auth_: BearerToken,
        data_review_rid: DataReviewRid,
    ) -> impl Future<Output = Result<DataReview, Error>> + Send;
    fn get_check_alert(
        &self,
        auth_: BearerToken,
        check_alert_rid: CheckAlertRid,
    ) -> impl Future<Output = Result<CheckAlert, Error>> + Send;
    fn get_check_alerts_for_data_review(
        &self,
        auth_: BearerToken,
        data_review_rid: DataReviewRid,
    ) -> impl Future<Output = Result<BTreeSet<CheckAlert>, Error>> + Send;
    fn get_check_alerts_histogram(
        &self,
        auth_: BearerToken,
        request: CheckAlertsHistogramRequest,
    ) -> impl Future<Output = Result<CheckAlertsHistogramResponse, Error>> + Send;
    fn search_check_alerts(
        &self,
        auth_: BearerToken,
        request: SearchCheckAlertsRequest,
    ) -> impl Future<Output = Result<SearchCheckAlertsResponse, Error>> + Send;
    fn get_check_alert_action_log(
        &self,
        auth_: BearerToken,
        check_alert_rid: CheckAlertRid,
    ) -> impl Future<Output = Result<CheckAlertActionLog, Error>> + Send;
    fn get_check_alert_counts_for_notebooks(
        &self,
        auth_: BearerToken,
        rids: BTreeSet<NotebookRid>,
    ) -> impl Future<Output = Result<BTreeMap<NotebookRid, i32>, Error>> + Send;
    fn get_check_alert_status_for_notebooks(
        &self,
        auth_: BearerToken,
        rids: BTreeSet<NotebookRid>,
    ) -> impl Future<Output = Result<BTreeMap<NotebookRid, Option<CheckAlertStatus>>, Error>> + Send;
    fn perform_check_alert_action(
        &self,
        auth_: BearerToken,
        check_alert_rid: CheckAlertRid,
        request: CheckAlertAction,
    ) -> impl Future<Output = Result<CheckAlert, Error>> + Send;
    fn batch_perform_check_alert_action(
        &self,
        auth_: BearerToken,
        request: BatchCheckAlertActionRequest,
    ) -> impl Future<Output = Result<BatchCheckAlertActionResponse, Error>> + Send;
    fn batch_perform_automatic_check_evaluation_review_action(
        &self,
        auth_: BearerToken,
        request: BatchAutomaticCheckEvaluationActionRequest,
    ) -> impl Future<Output = Result<BatchAutomaticCheckEvaluationActionResponse, Error>> + Send;
    fn get_automatic_check_evaluation_action_log(
        &self,
        auth_: BearerToken,
        rid: AutomaticCheckEvaluationRid,
    ) -> impl Future<Output = Result<AutomaticCheckEvaluationActionLog, Error>> + Send;
    fn batch_perform_manual_check_alert_action(
        &self,
        auth_: BearerToken,
        request: BatchManualCheckEvaluationActionRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn get_manual_check_evaluation_action_log(
        &self,
        auth_: BearerToken,
        rid: ManualCheckEvaluationRid,
    ) -> impl Future<Output = Result<ManualCheckEvaluationActionLog, Error>> + Send;
    fn archive_data_review(
        &self,
        auth_: BearerToken,
        data_review_rid: DataReviewRid,
    ) -> impl Future<Output = Result<bool, Error>> + Send;
    fn batch_archive_data_review(
        &self,
        auth_: BearerToken,
        rids: BTreeSet<DataReviewRid>,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn unarchive_data_review(
        &self,
        auth_: BearerToken,
        data_review_rid: DataReviewRid,
    ) -> impl Future<Output = Result<(), Error>> + Send;
}

The data review service manages the evaluation, disposition, and historical record of checks alerts.

Required Methods

fn batch_initiate( &self, auth_: BearerToken, request: BatchInitiateDataReviewRequest, ) -> impl Future<Output = Result<BatchInitiateDataReviewResponse, Error>> + Send

For each request, initiates data review for the requested run and checklist and executes the automatic checks against the run.

fn rerun_failed_automatic_checks( &self, auth_: BearerToken, request: RerunFailedAutomaticChecksRequest, ) -> impl Future<Output = Result<(), Error>> + Send

Re-executes the most recent failed automatic checks for the data review.

fn find_data_reviews( &self, auth_: BearerToken, request: FindDataReviewsRequest, ) -> impl Future<Output = Result<DataReviewPage, Error>> + Send

Returns the data reviews under the provided search parameters.

fn get( &self, auth_: BearerToken, data_review_rid: DataReviewRid, ) -> impl Future<Output = Result<DataReview, Error>> + Send

Throws if not found.

fn get_check_alert( &self, auth_: BearerToken, check_alert_rid: CheckAlertRid, ) -> impl Future<Output = Result<CheckAlert, Error>> + Send

Throws if not found.

fn get_check_alerts_for_data_review( &self, auth_: BearerToken, data_review_rid: DataReviewRid, ) -> impl Future<Output = Result<BTreeSet<CheckAlert>, Error>> + Send

Gets all check alerts from the provided data review.

fn get_check_alerts_histogram( &self, auth_: BearerToken, request: CheckAlertsHistogramRequest, ) -> impl Future<Output = Result<CheckAlertsHistogramResponse, Error>> + Send

Returns a histogram of alerts that occur across the provided runs or assets. At least one run or asset must be specified.

fn search_check_alerts( &self, auth_: BearerToken, request: SearchCheckAlertsRequest, ) -> impl Future<Output = Result<SearchCheckAlertsResponse, Error>> + Send

Returns the check alerts under the provided search parameters. At least one run or asset must be specified.

fn get_check_alert_action_log( &self, auth_: BearerToken, check_alert_rid: CheckAlertRid, ) -> impl Future<Output = Result<CheckAlertActionLog, Error>> + Send

Returns a record of the historical actions taken on the provided check alert.

fn get_check_alert_counts_for_notebooks( &self, auth_: BearerToken, rids: BTreeSet<NotebookRid>, ) -> impl Future<Output = Result<BTreeMap<NotebookRid, i32>, Error>> + Send

Returns the number of alerts attached to each provided notebook.

fn get_check_alert_status_for_notebooks( &self, auth_: BearerToken, rids: BTreeSet<NotebookRid>, ) -> impl Future<Output = Result<BTreeMap<NotebookRid, Option<CheckAlertStatus>>, Error>> + Send

Returns the check alert status of any linked violations for the provided notebooks. If none exist, an empty optional is returned.

fn perform_check_alert_action( &self, auth_: BearerToken, check_alert_rid: CheckAlertRid, request: CheckAlertAction, ) -> impl Future<Output = Result<CheckAlert, Error>> + Send

Applies a check alert action to the specified check alert RID.

fn batch_perform_check_alert_action( &self, auth_: BearerToken, request: BatchCheckAlertActionRequest, ) -> impl Future<Output = Result<BatchCheckAlertActionResponse, Error>> + Send

Applies a check alert action to the specified check alert RIDs. If any of the check actions fail, then none of the check actions will be applied.

fn batch_perform_automatic_check_evaluation_review_action( &self, auth_: BearerToken, request: BatchAutomaticCheckEvaluationActionRequest, ) -> impl Future<Output = Result<BatchAutomaticCheckEvaluationActionResponse, Error>> + Send

Applies an action to the specified check evaluation RIDs. If any of the check actions fail, then none of the actions will be applied.

fn get_automatic_check_evaluation_action_log( &self, auth_: BearerToken, rid: AutomaticCheckEvaluationRid, ) -> impl Future<Output = Result<AutomaticCheckEvaluationActionLog, Error>> + Send

fn batch_perform_manual_check_alert_action( &self, auth_: BearerToken, request: BatchManualCheckEvaluationActionRequest, ) -> impl Future<Output = Result<(), Error>> + Send

Applies an action to the specified check evaluation RIDs. If any of the check actions fail, then none of the actions will be applied.

fn get_manual_check_evaluation_action_log( &self, auth_: BearerToken, rid: ManualCheckEvaluationRid, ) -> impl Future<Output = Result<ManualCheckEvaluationActionLog, Error>> + Send

Returns a record of the historical manual actions taken on the provided check evaluation.

fn archive_data_review( &self, auth_: BearerToken, data_review_rid: DataReviewRid, ) -> impl Future<Output = Result<bool, Error>> + Send

Archives the data review with the given rid.

fn batch_archive_data_review( &self, auth_: BearerToken, rids: BTreeSet<DataReviewRid>, ) -> impl Future<Output = Result<(), Error>> + Send

Batch archives the data reviews with the given rids.

fn unarchive_data_review( &self, auth_: BearerToken, data_review_rid: DataReviewRid, ) -> impl Future<Output = Result<(), Error>> + Send

Unarchives the data review with the given rid.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors