Commitdeb93a0

committed

Merge branch 'main' into backend-refactors

2 parentsbbef428 +576eafc commitdeb93a0Copy full SHA for deb93a0

File tree

+13

-0

lines changed

+13

-0

lines changed

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -47,6 +47,10 @@ def next_n_rows(self, num_rows: int):`
`47`	`47`	`defremaining_rows(self):`
`48`	`48`	`pass`
`49`	`49`
	`50`	`+@abstractmethod`
	`51`	`+defclose(self):`
	`52`	`+pass`
	`53`	`+`
`50`	`54`
`51`	`55`	`classResultSetQueueFactory(ABC):`
`52`	`56`	`@staticmethod`
`@@ -159,6 +163,9 @@ def remaining_rows(self):`
`159`	`163`	`self.cur_row_index+=slice.num_rows`
`160`	`164`	`returnslice`
`161`	`165`
	`166`	`+defclose(self):`
	`167`	`+return`
	`168`	`+`
`162`	`169`
`163`	`170`	`classArrowQueue(ResultSetQueue):`
`164`	`171`	`def__init__(`
`@@ -195,6 +202,9 @@ def remaining_rows(self) -> "pyarrow.Table":`
`195`	`202`	`self.cur_row_index+=slice.num_rows`
`196`	`203`	`returnslice`
`197`	`204`
	`205`	`+defclose(self):`
	`206`	`+return`
	`207`	`+`
`198`	`208`
`199`	`209`	`classCloudFetchQueue(ResultSetQueue):`
`200`	`210`	`def__init__(`
`@@ -347,6 +357,9 @@ def _create_empty_table(self) -> "pyarrow.Table":`
`347`	`357`	`# Create a 0-row table with just the schema bytes`
`348`	`358`	`returncreate_arrow_table_from_arrow_file(self.schema_bytes,self.description)`
`349`	`359`
	`360`	`+defclose(self):`
	`361`	`+self.download_manager._shutdown_manager()`
	`362`	`+`
`350`	`363`
`351`	`364`	`ExecuteResponse=namedtuple(`
`352`	`365`	`"ExecuteResponse",`

Comments

(0)