Skip to content

Commit a6a9f79

Browse files
committed
update custom payload integration tests for PR apache#655
1 parent ba6f0e8 commit a6a9f79

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

tests/integration/standard/test_custom_protocol_handler.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -130,8 +130,9 @@ def recv_results_rows(cls, f, protocol_version, user_type_map, result_metadata):
130130
paging_state, column_metadata = cls.recv_results_metadata(f, user_type_map)
131131
rowcount = read_int(f)
132132
rows = [cls.recv_row(f, len(column_metadata)) for _ in range(rowcount)]
133+
colnames = [c[2] for c in column_metadata]
133134
coltypes = [c[3] for c in column_metadata]
134-
return (paging_state, (coltypes, rows))
135+
return paging_state, coltypes, (colnames, rows)
135136

136137

137138
class CustomTestRawRowType(ProtocolHandler):
@@ -166,7 +167,7 @@ def recv_results_rows(cls, f, protocol_version, user_type_map, result_metadata):
166167
tuple(ctype.from_binary(val, protocol_version)
167168
for ctype, val in zip(coltypes, row))
168169
for row in rows]
169-
return (paging_state, (colnames, parsed_rows))
170+
return paging_state, coltypes, (colnames, parsed_rows)
170171

171172

172173
class CustomProtocolHandlerResultMessageTracked(ProtocolHandler):

0 commit comments

Comments
 (0)