@@ -78,7 +78,7 @@ def update_next_page_offset(self, data, response_links=None):
7878 self .records_to_skip = self .records_to_skip + batch_size
7979 if batch_size == 0 :
8080 self .is_last_batch_empty = True
81- logger .info ("update_next_page:update_next_page :data is list:batch_size={}, records_to_skip={}, is_last_batch_empty={}" .format (
81+ logger .info ("update_next_page_offset :data is list:batch_size={}, records_to_skip={}, is_last_batch_empty={}" .format (
8282 batch_size , self .records_to_skip , self .is_last_batch_empty
8383 ))
8484 return
@@ -93,9 +93,9 @@ def update_next_page_offset(self, data, response_links=None):
9393 batch_size = 1
9494 if self .skip_key :
9595 self .skip = data .get (self .skip_key )
96- logger .info ("update_next_page :skip=data[{}]={}" .format (self .skip_key , self .skip ))
96+ logger .info ("update_next_page_offset :skip=data[{}]={}" .format (self .skip_key , self .skip ))
9797 self .records_to_skip = self .records_to_skip + batch_size
98- logger .info ("update_next_page :records_to_skip={}, batch_size={}" .format (self .records_to_skip , batch_size ))
98+ logger .info ("update_next_page_offset :records_to_skip={}, batch_size={}" .format (self .records_to_skip , batch_size ))
9999
100100
101101 def update_next_page_per_page (self , data , response_links = None ):
@@ -109,7 +109,7 @@ def update_next_page_per_page(self, data, response_links=None):
109109 self .records_to_skip = self .records_to_skip + batch_size
110110 if batch_size == 0 :
111111 self .is_last_batch_empty = True
112- logger .info ("update_next_page:update_next_page :data is list:batch_size={}, records_to_skip={}, is_last_batch_empty={}" .format (
112+ logger .info ("update_next_page_per_page :data is list:batch_size={}, records_to_skip={}, is_last_batch_empty={}" .format (
113113 batch_size , self .records_to_skip , self .is_last_batch_empty
114114 ))
115115 return
@@ -124,22 +124,22 @@ def update_next_page_per_page(self, data, response_links=None):
124124 batch_size = 1
125125 if self .skip_key :
126126 self .skip = data .get (self .skip_key )
127- logger .info ("update_next_page :skip=data[{}]={}" .format (self .skip_key , self .skip ))
127+ logger .info ("update_next_page_per_page :skip=data[{}]={}" .format (self .skip_key , self .skip ))
128128 self .records_to_skip = self .records_to_skip + batch_size
129- logger .info ("update_next_page :records_to_skip={}, batch_size={}" .format (self .records_to_skip , batch_size ))
129+ logger .info ("update_next_page_per_page :records_to_skip={}, batch_size={}" .format (self .records_to_skip , batch_size ))
130130
131131
132132 def update_next_page_link (self , data , response_links = None ):
133+ self .next_page_url = None
133134 response_links = response_links or {}
134135 next_link = response_links .get ('next' , {})
135136 next_page_url = next_link .get ("url" )
136137 self .is_first_batch = False
137138 self .counter += 1
138- # self.next_page_number = self.next_page_number + 1
139139 if next_page_url :
140140 self .next_page_url = next_page_url
141141 self .params_must_be_blanked = True
142- logger .info ("update_next_page :next_link={}, next_page_url={}, params_must_be_blanked={}, next_page_number={}, counter={}" .format (
142+ logger .info ("update_next_page_link :next_link={}, next_page_url={}, params_must_be_blanked={}, next_page_number={}, counter={}" .format (
143143 next_link , self .next_page_url , self .params_must_be_blanked , self .next_page_number , self .counter
144144 ))
145145 self .data_is_list = False
@@ -149,7 +149,7 @@ def update_next_page_link(self, data, response_links=None):
149149 self .next_page_url = "/" .join ([self .next_page_url_base , next_page_path ])
150150 else :
151151 self .next_page_url = next_page_path
152- logger .info ("update_next_page :next_page_url_base={}, next_page_path={}, next_page_url={}" .format (
152+ logger .info ("update_next_page_link :next_page_url_base={}, next_page_path={}, next_page_url={}" .format (
153153 self .next_page_url_base , next_page_path , self .next_page_url
154154 ))
155155
0 commit comments