in apply/src/awsqs_kubernetes_resource/vpc.py [0:0]
def proxy_call(cluster_name, manifest, command, sess):
event = {"cluster_name": cluster_name, "manifest": manifest, "command": command}
resp = invoke_function(
f"awsqs-kubernetes-resource-proxy-{cluster_name}", event, sess
)
if "errorMessage" in resp:
LOG.error(f'Code: {resp.get("errorType")} Message: {resp.get("errorMessage")}')
LOG.error(f'StackTrace: {resp.get("stackTrace")}')
raise Exception(f'{resp["errorType"]}: {resp["errorMessage"]}')
return resp