Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion pytd/query_engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,8 @@ def execute(self, query, **kwargs):
cur = self.cursor(**kwargs)
self.executed = cur.execute(query)
rows = cur.fetchall()
columns = [desc[0] for desc in cur.description]
# cur.description is None for CREATE and DROP statements in recent version of Trino
columns = [desc[0] for desc in cur.description] if cur.description else []
Comment thread
tung-vu-td marked this conversation as resolved.
Outdated
return {"data": rows, "columns": columns}

def create_header(self, extra_lines=[]):
Expand Down