chore(eks): kubectl 1.16.8-eks-e16311, aws-cli 1.18.86, helm 3.2.4

packages/@aws-cdk/aws-eks/lib/helm-chart.ts

@@ -53,6 +53,12 @@ export interface HelmChartOptions {
    * @default Duration.minutes(5)
    */
   readonly timeout?: Duration;
+
+  /**
+   * create namespace if not exist
+   * @default False
+   */
+  readonly createNamespace?: boolean;
 }
 
 /**
@@ -104,6 +110,7 @@ export class HelmChart extends Construct {
         Values: (props.values ? stack.toJsonString(props.values) : undefined),
         Namespace: props.namespace ?? 'default',
         Repository: props.repository,
+        CreateNamespace: props.createNamespace ?? false,
       },
     });
   }

packages/@aws-cdk/aws-eks/lib/kubectl-handler/helm/__init__.py

@@ -12,6 +12,7 @@
 outdir = os.environ.get('TEST_OUTDIR', '/tmp')
 kubeconfig = os.path.join(outdir, 'kubeconfig')
 
+
 def helm_handler(event, context):
     logger.info(json.dumps(event))
 
@@ -20,22 +21,23 @@ def helm_handler(event, context):
 
     # resource properties
     cluster_name = props['ClusterName']
-    role_arn     = props['RoleArn']
-    release      = props['Release']
-    chart        = props['Chart']
-    version      = props.get('Version', None)
-    wait         = props.get('Wait', False)
-    timeout      = props.get('Timeout', None)
-    namespace    = props.get('Namespace', None)
-    repository   = props.get('Repository', None)
-    values_text  = props.get('Values', None)
+    role_arn = props['RoleArn']
+    release = props['Release']
+    chart = props['Chart']
+    version = props.get('Version', None)
+    wait = props.get('Wait', False)
+    timeout = props.get('Timeout', None)
+    namespace = props.get('Namespace', None)
+    create_namespace = props.get('CreateNamespace', None)
+    repository = props.get('Repository', None)
+    values_text = props.get('Values', None)
 
     # "log in" to the cluster
-    subprocess.check_call([ 'aws', 'eks', 'update-kubeconfig',
-        '--role-arn', role_arn,
-        '--name', cluster_name,
-        '--kubeconfig', kubeconfig
-    ])
+    subprocess.check_call(['aws', 'eks', 'update-kubeconfig',
+                           '--role-arn', role_arn,
+                           '--name', cluster_name,
+                           '--kubeconfig', kubeconfig
+                           ])
 
     # Write out the values to a file and include them with the install and upgrade
     values_file = None
@@ -46,21 +48,26 @@ def helm_handler(event, context):
             f.write(json.dumps(values, indent=2))
 
     if request_type == 'Create' or request_type == 'Update':
-        helm('upgrade', release, chart, repository, values_file, namespace, version, wait, timeout)
+        helm('upgrade', release, chart, repository, values_file, namespace, version, wait, timeout, create_namespace)
     elif request_type == "Delete":
         try:
             helm('uninstall', release, namespace=namespace, timeout=timeout)
         except Exception as e:
             logger.info("delete error: %s" % e)
 
-def helm(verb, release, chart = None, repo = None, file = None, namespace = None, version = None, wait = False, timeout = None):
+
+def helm(
+        verb, release, chart=None, repo=None, file=None, namespace=None, version=None, wait=False, timeout=None,
+        create_namespace=None):
     import subprocess
 
     cmnd = ['helm', verb, release]
     if not chart is None:
         cmnd.append(chart)
     if verb == 'upgrade':
         cmnd.append('--install')
+    if not create_namespace is None:
+        cmnd.append('--create-namespace')
     if not repo is None:
         cmnd.extend(['--repo', repo])
     if not file is None:
@@ -72,9 +79,11 @@ def helm(verb, release, chart = None, repo = None, file = None, namespace = None
     if wait:
         cmnd.append('--wait')
     if not timeout is None:
-        cmnd.extend(['--timeout', timeout])  
+        cmnd.extend(['--timeout', timeout])
     cmnd.extend(['--kubeconfig', kubeconfig])
 
+    logger.info(cmnd)
+
     retry = 3
     while retry > 0:
         try:

packages/@aws-cdk/aws-eks/lib/kubectl-provider.ts

@@ -24,7 +24,7 @@ export class KubectlProvider extends NestedStack {
       runtime: lambda.Runtime.PYTHON_3_7,
       handler: 'index.handler',
       timeout: Duration.minutes(15),
-      layers: [ KubectlLayer.getOrCreate(this, { version: '2.0.0-beta2' }) ],
+      layers: [ KubectlLayer.getOrCreate(this, { version: '2.0.0' }) ],
       memorySize: 256,
     });