Commit097a2c5

authored

Removed use_threads argument on concat_tables for compatibility with pyarrow<14 (#684)

removed use_threads

1 parent9e67c79 commit097a2c5Copy full SHA for 097a2c5

File tree

-3

lines changed

-3

lines changed

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -298,7 +298,7 @@ def next_n_rows(self, num_rows: int) -> "pyarrow.Table":`
`298`	`298`	`num_rows-=table_slice.num_rows`
`299`	`299`
`300`	`300`	`logger.debug("CloudFetchQueue: collected {} next rows".format(results.num_rows))`
`301`		`-returnpyarrow.concat_tables(partial_result_chunks,use_threads=True)`
	`301`	`+returnconcat_table_chunks(partial_result_chunks)`
`302`	`302`
`303`	`303`	`defremaining_rows(self)->"pyarrow.Table":`
`304`	`304`	`"""`
`@@ -321,7 +321,7 @@ def remaining_rows(self) -> "pyarrow.Table":`
`321`	`321`	`self.table_row_index+=table_slice.num_rows`
`322`	`322`	`self.table=self._create_next_table()`
`323`	`323`	`self.table_row_index=0`
`324`		`-returnpyarrow.concat_tables(partial_result_chunks,use_threads=True)`
	`324`	`+returnconcat_table_chunks(partial_result_chunks)`
`325`	`325`
`326`	`326`	`def_create_table_at_offset(self,offset:int)->Union["pyarrow.Table",None]:`
`327`	`327`	`"""Create next table at the given row offset"""`
`@@ -880,7 +880,7 @@ def concat_table_chunks(`
`880`	`880`	`result_table[j].extend(table_chunks[i].column_table[j])`
`881`	`881`	`returnColumnTable(result_table,table_chunks[0].column_names)`
`882`	`882`	`else:`
`883`		`-returnpyarrow.concat_tables(table_chunks,use_threads=True)`
	`883`	`+returnpyarrow.concat_tables(table_chunks)`
`884`	`884`
`885`	`885`
`886`	`886`	`defbuild_client_context(server_hostname:str,version:str,**kwargs):`

Comments

(0)