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())