def notify_when_app_is_not_running()

in amazon_kinesis_data_analytics_for_apache_flink_snapshot_manager.py [0:0]


def notify_when_app_is_not_running(sns, topic_arn, flink_app_name, snapshot_manager_run_id):
    """
    This function sends a notification to Amazon SNS Topic
    :param sns:
    :param topic_arn:
    :param flink_app_name:
    :param snapshot_manager_run_id:
    :return:
    """
    message = """