<reponame>tvorogme/ambari-airflow-service
from resource_management import Execute, Script, File, Template, Directory
from resource_management.core.exceptions import ExecutionFailed
import os


class AirflowBase(Script):

    def install_airflow(self, env):
        import params
        env.set_params(params)

        Execute('yum groupinstall -y "Development Tools"')
        Execute("/opt/anaconda/bin/pip3 install 'pyqtwebengine<5.13' --force-reinstall")
        Execute('/opt/anaconda/bin/pip3 install "pyqt5<5.13" --force-reinstall')

        Execute('/opt/anaconda/bin/pip3 install apache-airflow==1.10.6 --constraint "https://raw.githubusercontent.com/apache/airflow/constraints-1-10/constraints-3.8.txt"')
        Directory(params.airflow_home_directory,
                  create_parents=True,
                  owner='root',
                  group='root',
                  mode=0o0755)

        Execute('export AIRFLOW_HOME={0} && /opt/anaconda/bin/airflow initdb'.format(params.airflow_home_directory))

        Execute('/opt/anaconda/bin/pip3 uninstall SQLAlchemy -y')
        Execute('/opt/anaconda/bin/pip3 install SQLAlchemy==1.3.15')
        try:
            self.configure_airflow(env)
        except ExecutionFailed as ef:
            print("Error {0}".format(ef))
            return


    def configure_airflow(self, env):
        import params
        env.set_params(params)

        File("/etc/systemd/system/airflow_webserver.service",
             content=Template("webserver.j2",
                              configurations=params),
             owner='root',
             group='root',
             mode=0o0600
             )

        File("/etc/systemd/system/airflow_scheduler.service",
             content=Template("scheduler.j2",
                              configurations=params),
             owner='root',
             group='root',
             mode=0o0600
             )

        Execute('sudo systemctl daemon-reload')

    def install(self, env):
        self.install_airflow(self, env)

from resource_management import Execute, Script, File, Template, Directory
from resource_management.core.exceptions import ExecutionFailed
import os


class AirflowBase(Script):

    def install_airflow(self, env):
        import params
        env.set_params(params)

        Execute('yum groupinstall -y "Development Tools"')
        Execute("/opt/anaconda/bin/pip3 install 'pyqtwebengine<5.13' --force-reinstall")
        Execute('/opt/anaconda/bin/pip3 install "pyqt5<5.13" --force-reinstall')

        Execute('/opt/anaconda/bin/pip3 install apache-airflow==1.10.6 --constraint "https://raw.githubusercontent.com/apache/airflow/constraints-1-10/constraints-3.8.txt"')
        Directory(params.airflow_home_directory,
                  create_parents=True,
                  owner='root',
                  group='root',
                  mode=0o0755)

        Execute('export AIRFLOW_HOME={0} && /opt/anaconda/bin/airflow initdb'.format(params.airflow_home_directory))

        Execute('/opt/anaconda/bin/pip3 uninstall SQLAlchemy -y')
        Execute('/opt/anaconda/bin/pip3 install SQLAlchemy==1.3.15')
        try:
            self.configure_airflow(env)
        except ExecutionFailed as ef:
            print("Error {0}".format(ef))
            return


    def configure_airflow(self, env):
        import params
        env.set_params(params)

        File("/etc/systemd/system/airflow_webserver.service",
             content=Template("webserver.j2",
                              configurations=params),
             owner='root',
             group='root',
             mode=0o0600
             )

        File("/etc/systemd/system/airflow_scheduler.service",
             content=Template("scheduler.j2",
                              configurations=params),
             owner='root',
             group='root',
             mode=0o0600
             )

        Execute('sudo systemctl daemon-reload')

    def install(self, env):
        self.install_airflow(self, env)