# from __future__ import division, absolute_import, print_function

from airflow.plugins_manager import AirflowPlugin

import operators

import helpers


class ETLPlugin(AirflowPlugin):
    name = "etl_plugin"
    operators = [
        operators.StageToRedshiftOperator,
        operators.LoadTableOperator,
        operators.DataQualityOperator,
    ]
    helpers = [helpers.SqlQueries, helpers.DataValidationQueries]

6b9147e22af3acd11550d7c20a752c2d0dce2fc3
<mask token>

<mask token>


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

<mask token>


class ETLPlugin(AirflowPlugin):
    name = 'etl_plugin'
    operators = [operators.StageToRedshiftOperator, operators.
        LoadTableOperator, operators.DataQualityOperator]
    helpers = [helpers.SqlQueries, helpers.DataValidationQueries]

from airflow.plugins_manager import AirflowPlugin
import operators
import helpers


class ETLPlugin(AirflowPlugin):
    name = 'etl_plugin'
    operators = [operators.StageToRedshiftOperator, operators.
        LoadTableOperator, operators.DataQualityOperator]
    helpers = [helpers.SqlQueries, helpers.DataValidationQueries]

# from __future__ import division, absolute_import, print_function

from airflow.plugins_manager import AirflowPlugin

import operators

import helpers


class ETLPlugin(AirflowPlugin):
    name = "etl_plugin"
    operators = [
        operators.StageToRedshiftOperator,
        operators.LoadTableOperator,
        operators.DataQualityOperator,
    ]
    helpers = [helpers.SqlQueries, helpers.DataValidationQueries]
