@@ -69,7 +69,6 @@ def set_counting_key(self, counting_key):
6969 def update_next_page_offset (self , data , response_links = None ):
7070 self .is_first_batch = False
7171 self .counter += 1
72- #self.next_page_number = self.next_page_number + 1
7372 self .data_is_list = False
7473 if isinstance (data , list ):
7574 self .data_is_list = True
@@ -90,9 +89,6 @@ def update_next_page_offset(self, data, response_links=None):
9089 self .is_last_batch_empty = True
9190 else :
9291 batch_size = 1
93- #if self.skip_key:
94- # self.skip = data.get(self.skip_key)
95- # logger.info("update_next_page_offset:skip=data[{}]={}".format(self.skip_key, self.skip))
9692 self .records_to_skip = self .records_to_skip + batch_size
9793 logger .info ("update_next_page_offset:data_is_list={}, records_to_skip={}, batch_size={}, is_last_batch_empty={}" .format (
9894 self .data_is_list , self .records_to_skip , batch_size , self .is_last_batch_empty
@@ -107,7 +103,6 @@ def update_next_page_per_page(self, data, response_links=None):
107103 if isinstance (data , list ):
108104 self .data_is_list = True
109105 batch_size = len (data )
110- #self.records_to_skip = self.records_to_skip + batch_size
111106 if batch_size == 0 :
112107 self .is_last_batch_empty = True
113108 logger .info ("update_next_page_per_page:data is list:batch_size={}, next_page_number={}, is_last_batch_empty={}" .format (
@@ -123,10 +118,6 @@ def update_next_page_per_page(self, data, response_links=None):
123118 self .is_last_batch_empty = True
124119 else :
125120 batch_size = 1
126- #if self.skip_key:
127- # self.skip = data.get(self.skip_key)
128- # logger.info("update_next_page_per_page:skip=data[{}]={}".format(self.skip_key, self.skip))
129- #self.records_to_skip = self.records_to_skip + batch_size
130121 logger .info ("update_next_page_per_page:data_is_list={}, next_page_number={}, batch_size={}, is_last_batch_empty={}" .format (
131122 self .data_is_list , self .next_page_number , batch_size , self .is_last_batch_empty
132123 ))
0 commit comments