def c()

in app/lambda/testAthena.py [0:0]
41 lines of code
1 McCabe index (conditional complexity)

def c():
    queryString = 'CREATE DATABASE IF NOT EXISTS ' + databaseName
    client.start_query_execution(QueryString=queryString, ResultConfiguration=resultConfiguration)

    queryString = '''CREATE EXTERNAL TABLE IF NOT EXISTS Comprehend ( 
                        Session struct<sessionId: string,
                                        patientId: string,
                                        healthCareProfessionalId: string,
                                        timeStampStart: bigint,
                                        timeStampEnd: bigint>,
                        Medication array<
                                struct<medicationId: string,
                                    sessionId: string,
                                    medicationText: string,
                                    medicationType: string>>,
                        RXNorm array<struct<code: bigint, description: string>>,
                        MedicationRxNorm array<struct<medicationId: string, code: bigint>>,
                        MedicalCondition array<
                                        struct<medicalConditionId: string, 
                                                sessionId: string, 
                                                medicalConditionText: string>>,
                        ICD10CMConcept array<struct<code: string, description: string>>,
                        MedicalConditionICD10CMConcept array<struct<medicalConditionId: string, code: string>>,
                        TestTreatmentProcedures array<
                                                struct<testTreatmentProcedureId: string,
                                                        sessionId: string,
                                                        testTreatmentProcedureText: string,
                                                        testTreatmentProcedureType: string>>
                        
                        )
                        ROW FORMAT SERDE "org.openx.data.jsonserde.JsonSerDe"
                        LOCATION "s3://mtastack-mtastackstorages3bucketc161f3b3-1tfncqzctldb1/public/comprehend-medical-output/"'''
    client.start_query_execution(QueryString=queryString, QueryExecutionContext=queryExecutionContext, ResultConfiguration=resultConfiguration)

    queryString = '''CREATE OR REPLACE VIEW SessionView AS
                            SELECT 
                                Session.sessionId, 
                                Session.patientId, 
                                Session.healthCareProfessionalId,
                                Session.timeStampStart,
                                Session.timeStampEnd
                            FROM Comprehend;''' # Session
    print(queryExecutionContext)
    response1 = client.start_query_execution(QueryString=queryString, QueryExecutionContext=queryExecutionContext, ResultConfiguration=resultConfiguration)