def delete_snapshot()

in amazon_kinesis_data_analytics_for_apache_flink_snapshot_manager.py [0:0]

• 16 lines of code
• 4 McCabe index (conditional complexity)

def delete_snapshot(kin_analytics, flink_app_name, snapshot):
    """
    This function deletes a Flink snapshot
    :param kin_analytics:
    :param flink_app_name:
    :param snapshot:
    :return:
    """
    is_snapshot_deleted = False
    try:
        res = kin_analytics.delete_application_snapshot(
            ApplicationName=flink_app_name,
            SnapshotName=snapshot['SnapshotName'],
            SnapshotCreationTimestamp=snapshot['SnapshotCreationTimestamp']
        )
        if res['ResponseMetadata']['HTTPStatusCode'] == 200:
            is_snapshot_deleted = True
    except botocore.exceptions.ClientError as error:
        if error.response['Error']['Code'] == 'ResourceNotFoundException':
            logger.warning('The requested Kinesis Data Analytics Flink Application was not found')
        else:
            print('Error Message: {}'.format(error.response['Error']['Message']))
    return is_snapshot_deleted