great_expectations.checkpoint.util

Module Contents

Functions

send_slack_notification(query, slack_webhook=None, slack_channel=None, slack_token=None)

send_opsgenie_alert(query, suite_name, settings)

Creates an alert in Opsgenie.

send_microsoft_teams_notifications(query, microsoft_teams_webhook)

send_webhook_notifications(query, webhook, target_platform)

send_email(title, html, smtp_address, smtp_port, sender_login, sender_password, sender_alias, receiver_emails_list, use_tls, use_ssl)

get_substituted_validation_dict(substituted_runtime_config: dict, validation_dict: dict)

get_substituted_batch_request(substituted_runtime_config: dict, validation_batch_request: Optional[Union[BatchRequestBase, dict]] = None)

substitute_template_config(source_config: dict, template_config: dict)

substitute_runtime_config(source_config: dict, runtime_kwargs: dict)

get_updated_action_list(base_action_list: list, other_action_list: list)

batch_request_in_validations_contains_batch_data(validations: Optional[List[dict]] = None)

get_validations_with_batch_request_as_dict(validations: Optional[list] = None)

validate_validation_dict(validation_dict: dict)

send_cloud_notification(url: str, headers: dict)

Post a CloudNotificationAction to GX Cloud Backend for processing.

send_sns_notification(sns_topic_arn: str, sns_subject: str, validation_results: str, **kwargs)

Send JSON results to an SNS topic with a schema of:

great_expectations.checkpoint.util.boto3
great_expectations.checkpoint.util.logger
great_expectations.checkpoint.util.send_slack_notification(query, slack_webhook=None, slack_channel=None, slack_token=None)
great_expectations.checkpoint.util.send_opsgenie_alert(query, suite_name, settings)

Creates an alert in Opsgenie.

great_expectations.checkpoint.util.send_microsoft_teams_notifications(query, microsoft_teams_webhook)
great_expectations.checkpoint.util.send_webhook_notifications(query, webhook, target_platform)
great_expectations.checkpoint.util.send_email(title, html, smtp_address, smtp_port, sender_login, sender_password, sender_alias, receiver_emails_list, use_tls, use_ssl)
great_expectations.checkpoint.util.get_substituted_validation_dict(substituted_runtime_config: dict, validation_dict: dict) → dict
great_expectations.checkpoint.util.get_substituted_batch_request(substituted_runtime_config: dict, validation_batch_request: Optional[Union[BatchRequestBase, dict]] = None) → Optional[Union[BatchRequest, RuntimeBatchRequest]]
great_expectations.checkpoint.util.substitute_template_config(source_config: dict, template_config: dict) → dict
great_expectations.checkpoint.util.substitute_runtime_config(source_config: dict, runtime_kwargs: dict) → dict
great_expectations.checkpoint.util.get_updated_action_list(base_action_list: list, other_action_list: list) → List[dict]
great_expectations.checkpoint.util.batch_request_in_validations_contains_batch_data(validations: Optional[List[dict]] = None) → bool
great_expectations.checkpoint.util.get_validations_with_batch_request_as_dict(validations: Optional[list] = None) → Optional[list]
great_expectations.checkpoint.util.validate_validation_dict(validation_dict: dict) → None
great_expectations.checkpoint.util.send_cloud_notification(url: str, headers: dict)

Post a CloudNotificationAction to GX Cloud Backend for processing.

great_expectations.checkpoint.util.send_sns_notification(sns_topic_arn: str, sns_subject: str, validation_results: str, **kwargs) → str

Send JSON results to an SNS topic with a schema of:

Parameters
  • sns_topic_arn – The SNS Arn to publish messages to

  • sns_subject – : The SNS Message Subject - defaults to expectation_suite_identifier.expectation_suite_name

  • validation_results – The results of the validation ran

  • kwargs – Keyword arguments to pass to the boto3 Session

Returns

Message ID that was published