from __future__ import division, absolute_import, print_function

from airflow.plugins_manager import AirflowPlugin

import operators
import helpers


# Defining the plugin class
class SparkifyPlugin(AirflowPlugin):
    name = "sparkify_plugin"

    operators = [
        operators.StageToRedshiftOperator,
        operators.LoadFactOperator,
        operators.LoadDimensionOperator,
        operators.DataQualityOperator
    ]

    helpers = [
        helpers.table_to_query_map,
        helpers.LoadOperatorMode,
        helpers.SaveMode,
        helpers.DataQualityCheckBase,
        helpers.DataQualityCheckType,
        helpers.TableIsNotEmptyDataQualityCheck,
        helpers.ColumnDoesNotContainNullsDataQualityCheck,
        helpers.CustomDataQualityCheck
    ]

7211cad636575140a91973432f2b718f25d13642
<mask token>

<mask token>


class SparkifyPlugin(AirflowPlugin):
    <mask token>
    <mask token>
    <mask token>

<mask token>


class SparkifyPlugin(AirflowPlugin):
    name = 'sparkify_plugin'
    operators = [operators.StageToRedshiftOperator, operators.
        LoadFactOperator, operators.LoadDimensionOperator, operators.
        DataQualityOperator]
    helpers = [helpers.table_to_query_map, helpers.LoadOperatorMode,
        helpers.SaveMode, helpers.DataQualityCheckBase, helpers.
        DataQualityCheckType, helpers.TableIsNotEmptyDataQualityCheck,
        helpers.ColumnDoesNotContainNullsDataQualityCheck, helpers.
        CustomDataQualityCheck]

from __future__ import division, absolute_import, print_function
from airflow.plugins_manager import AirflowPlugin
import operators
import helpers


class SparkifyPlugin(AirflowPlugin):
    name = 'sparkify_plugin'
    operators = [operators.StageToRedshiftOperator, operators.
        LoadFactOperator, operators.LoadDimensionOperator, operators.
        DataQualityOperator]
    helpers = [helpers.table_to_query_map, helpers.LoadOperatorMode,
        helpers.SaveMode, helpers.DataQualityCheckBase, helpers.
        DataQualityCheckType, helpers.TableIsNotEmptyDataQualityCheck,
        helpers.ColumnDoesNotContainNullsDataQualityCheck, helpers.
        CustomDataQualityCheck]

from __future__ import division, absolute_import, print_function

from airflow.plugins_manager import AirflowPlugin

import operators
import helpers


# Defining the plugin class
class SparkifyPlugin(AirflowPlugin):
    name = "sparkify_plugin"

    operators = [
        operators.StageToRedshiftOperator,
        operators.LoadFactOperator,
        operators.LoadDimensionOperator,
        operators.DataQualityOperator
    ]

    helpers = [
        helpers.table_to_query_map,
        helpers.LoadOperatorMode,
        helpers.SaveMode,
        helpers.DataQualityCheckBase,
        helpers.DataQualityCheckType,
        helpers.TableIsNotEmptyDataQualityCheck,
        helpers.ColumnDoesNotContainNullsDataQualityCheck,
        helpers.CustomDataQualityCheck
    ]
