def create_kubeconfig()

in apply/src/awsqs_kubernetes_resource/utils.py [0:0]

• 15 lines of code
• 2 McCabe index (conditional complexity)

def create_kubeconfig(cluster_name, session=None):
    os.environ["PATH"] = f"/var/task/bin:{os.environ['PATH']}"
    os.environ["PYTHONPATH"] = f"/var/task:{os.environ.get('PYTHONPATH', '')}"
    os.environ["KUBECONFIG"] = "/tmp/kube.config"
    if session:
        creds = session.client.__self__.get_credentials()
        os.environ["AWS_ACCESS_KEY_ID"] = creds.access_key
        os.environ["AWS_SECRET_ACCESS_KEY"] = creds.secret_key
        os.environ["AWS_SESSION_TOKEN"] = creds.token
    run_command(
        f"aws eks update-kubeconfig --name {cluster_name} --alias {cluster_name} --kubeconfig /tmp/kube.config",
        None,
        None,
    )
    run_command(f"kubectl config use-context {cluster_name}", None, None)