Airflow from helm simple example

airflow_start_via_helm.py

import base64
import os
import subprocess

def run_command(cmd):
    print (f">{cmd}")
    ret_code = subprocess.call(cmd, shell=True)
    print (f'>> Return Code: {ret_code}')
    return ret_code

def get_fernet_key():
    return base64.urlsafe_b64encode(os.urandom(32)).decode()

def main():
    run_command(f'''helm install airflow apache-airflow/airflow --namespace airflow \
        --set fernetKey={get_fernet_key()}
        --set executor="KubernetesExecutor"
        --set dags.gitSync.depth=1
        --set dags.persistence.enabled=true
        --set logs.persistence.enabled=true
        --set dags.gitSync.enabled=true
        --set dags.gitSync.repo="https://github.com/apache/airflow.git"
        --set dags.gitSync.subPath="airflow/example_dags"
        --set dags.gitSync.rev="HEAD"
'''.replace("\n", " "))


if __name__ == '__main__':
    main()