def s3_get()

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


def s3_get(url, s3_client):
    try:
        return (
            s3_client.get_object(
                Bucket=url.split("/")[2], Key="/".join(url.split("/")[3:])
            )["Body"]
            .read()
            .decode("utf8")
        )
    except Exception as e:
        raise RuntimeError(f"Failed to fetch CustomValueYaml {url} from S3. {e}")