def pusblishTripCompletionInfo()

in src/ddb-stream-processor/lambda_function.py [0:0]

• 10 lines of code
• 2 McCabe index (conditional complexity)

def pusblishTripCompletionInfo(sqlCmds):
    
    conn = pg8000.connect(database=PGDATABASE, host=PGHOST, port=PGPORT, user=PGUSER, password=PGPASSWORD)
    cursor = conn.cursor()
    
    for cmd in sqlCmds:
        print("Executing Query:" + cmd)
        cursor.execute(cmd)
        print("Completed Executing Query:" + cmd)
        
    #queryOuts = cursor.fetchall()
    cursor.close()
    conn.commit()
        
    #for out in queryOuts:
    #    print(out)
        
    return