def kubectl_get()

in get/src/awsqs_kubernetes_get/handlers.py [0:0]

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

def kubectl_get(model: ResourceModel, sess) -> ProgressEvent    :
    LOG.info('Received model: %s' % json.dumps(model._serialize()))
    if not proxy_needed(model.ClusterName, sess):
        create_kubeconfig(model.ClusterName, sess)
    model.Response = run_command(
        'kubectl get %s -o jsonpath="%s" --namespace %s' % (model.Name, model.JsonPath, model.Namespace),
        model.ClusterName,
        sess
    )
    LOG.info("returning progress...")
    return ProgressEvent(
        status=OperationStatus.SUCCESS,
        resourceModel=model,
    )