def __init__()

in cloudformation/custom_resources/sqsInvokedFunction/gqllayer.py [0:0]

• 25 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, **kwargs):
        self.__dict__.update(kwargs)

        # get temporary creds from lambda env
        awsauth = AWS4Auth(
            getenv('AWS_ACCESS_KEY_ID'),
            getenv('AWS_SECRET_ACCESS_KEY'),
            getenv('AWS_REGION'),
            'appsync',
            session_token=getenv('AWS_SESSION_TOKEN')
        )

        headers = {
            'Content-Type': 'application/json'
        }

        appsync_endpoint = getenv('APPSYNC_ENDPOINT')

        job_import_transport = RequestsHTTPTransport(
            url=appsync_endpoint,
            use_json=True,
            headers=headers,
            verify=True,
            retries=3,
            auth=awsauth
        )

        self._client = Client(
            transport=job_import_transport,
            fetch_schema_from_transport=True
        )