def proxy_wrap()

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


def proxy_wrap(event, _context):
    LOG.debug(json.dumps(event))
    if event.get("manifest"):
        with open("/tmp/manifest.yaml", 'w') as f:
            f.write(event["manifest"])
        with open("/tmp/manifest.yaml", 'r') as f:
            LOG.debug(f.read())
    create_kubeconfig(event["cluster_name"])
    return run_command(event["command"], event["cluster_name"], boto3.session.Session())