File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -183,7 +183,7 @@ def _update_producer_new_links_stat(self):
183183
184184 def frontier_stop (self ):
185185 if self .producer :
186- n_flushed_links = self .producer .flush ()
186+ self .producer .flush ()
187187 self .producer .close ()
188188 self ._update_producer_new_links_stat ()
189189
@@ -309,7 +309,7 @@ def _process_hcf_link(self, link):
309309
310310 slot = self .hcf_get_producer_slot (link )
311311 if slot :
312- n_flushed_links = self .producer .add_request (slot , convert_from_bytes (hcf_request ))
312+ self .producer .add_request (slot , convert_from_bytes (hcf_request ))
313313
314314 self .stats .inc_value (self ._get_producer_stats_msg (slot , msg = 'total_links' ))
315315 self .stats .inc_value (self ._get_producer_stats_msg (msg = 'total_links' ))
You can’t perform that action at this time.
0 commit comments