Commit 1b80a6c1 by Oleksandr Barabash

get_next_page renamed to get_next_page_bl

parent 75584bf8
...@@ -115,7 +115,8 @@ class CosmosClient: ...@@ -115,7 +115,8 @@ class CosmosClient:
return await self.execute_blocking(bl) return await self.execute_blocking(bl)
def get_next_page_bl(self, pager): @staticmethod
def get_next_page_bl(pager):
""" Get Next page items Blocking """ """ Get Next page items Blocking """
try: try:
# todo(s1z): why do we get [0], as MS does? This is bad!!! # todo(s1z): why do we get [0], as MS does? This is bad!!!
...@@ -145,7 +146,7 @@ class CosmosClient: ...@@ -145,7 +146,7 @@ class CosmosClient:
max_item_count=1 max_item_count=1
) )
pager = query_iterable.by_page(token) pager = query_iterable.by_page(token)
items = self.get_next_page(pager) items = self.get_next_page_bl(pager)
continuation_token = pager.continuation_token continuation_token = pager.continuation_token
return ( return (
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment