def proxy_call()

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