from datapipe.pipelines.bigsql_exec import BigSQLExec
from datapipe.pipelines.hdfs_export import HdfsExport
from datapipe.pipelines.hdfs_import import HdfsImport
from datapipe.pipelines.sqoop_export import SqoopExport
from datapipe.pipelines.sqoop_import import SqoopImport
from datapipe.utils.constantes import *

PIPELINES_DISPONIVEIS = {
    YAML_SCOOP_IMPORT: SqoopImport,
    YAML_SCOOP_EXPORT: SqoopExport,
    YAML_BIGSQL_EXEC: BigSQLExec,
    YAML_HDFS_EXPORT: HdfsExport,
    YAML_HDFS_IMPORT: HdfsImport,
    # YAML_PYTHON_SCRIPT: PythonScript,
}

from datapipe.pipelines.bigsql_exec import BigSQLExec
from datapipe.pipelines.hdfs_export import HdfsExport
from datapipe.pipelines.hdfs_import import HdfsImport
from datapipe.pipelines.sqoop_export import SqoopExport
from datapipe.pipelines.sqoop_import import SqoopImport
from datapipe.utils.constantes import *

PIPELINES_DISPONIVEIS = {
    YAML_SCOOP_IMPORT: SqoopImport,
    YAML_SCOOP_EXPORT: SqoopExport,
    YAML_BIGSQL_EXEC: BigSQLExec,
    YAML_HDFS_EXPORT: HdfsExport,
    YAML_HDFS_IMPORT: HdfsImport,
    # YAML_PYTHON_SCRIPT: PythonScript,
}

# YAML_PYTHON_SCRIPT: PythonScript,