Skip to content

Attributes

spark_expectations.notifications.plugins.base_notification.SPARK_EXPECTATIONS_NOTIFICATION_PLUGIN = 'spark_expectations_notification_plugins' module-attribute

spark_expectations.notifications.plugins.base_notification.notification_plugin_spec = pluggy.HookspecMarker(SPARK_EXPECTATIONS_NOTIFICATION_PLUGIN) module-attribute

spark_expectations.notifications.plugins.base_notification.spark_expectations_notification_impl = pluggy.HookimplMarker(SPARK_EXPECTATIONS_NOTIFICATION_PLUGIN) module-attribute

Classes

spark_expectations.notifications.plugins.base_notification.SparkExpectationsNotification

This is base class for notifications plugin

Functions

send_notification(_context: SparkExpectationsContext, _config_args: Dict[Union[str], Union[str, bool]]) -> None

function consist signature to notification, which will be implemented in the child class

Parameters:

Name Type Description Default
_context SparkExpectationsContext

object of SparkExpectationsContext

 required
_config_args Dict[Union[str], Union[str, bool]]

dict which contains required parameter to send notification

 required
Source code in spark_expectations/notifications/plugins/base_notification.py 
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
@notification_plugin_spec
def send_notification(
    self,
    _context: SparkExpectationsContext,
    _config_args: Dict[Union[str], Union[str, bool]],
) -> None:
    """
    function consist signature to notification, which will be implemented in the child class
    Args:
        _context:object of SparkExpectationsContext
        _config_args: dict which contains required parameter to send notification

    Returns: None

    """
    pass