Skip to content

Commit

Permalink
code style, name method
Browse files Browse the repository at this point in the history
  • Loading branch information
alexanderlz committed Mar 23, 2016
1 parent 3e8c127 commit 5b663eb
Showing 1 changed file with 7 additions and 3 deletions.
10 changes: 7 additions & 3 deletions query_runner/dynamodb_sql.py
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,11 @@ def annotate_query(cls):

@classmethod
def type(cls):
return "ddb_sql"
return "dynamodb_sql"

@classmethod
def name(cls):
return "DynamoDB (with DQL)"

def __init__(self, configuration):
super(DynamoDBSQL, self).__init__(configuration)
Expand All @@ -99,11 +103,11 @@ def run_query(self, query):
engine = FragmentEngine()
connection = engine.connect(**self.configuration.to_dict())

resDict = engine.execute(query if str(query).endswith(';') else str(query)+';')
res_dict = engine.execute(query if str(query).endswith(';') else str(query)+';')

columns = []
rows = []
for item in resDict:
for item in res_dict:

if not columns:
for k, v in item.iteritems():
Expand Down

0 comments on commit 5b663eb

Please sign in to comment.