Skip to content

Commit

Permalink
remove unused variables
Browse files Browse the repository at this point in the history
  • Loading branch information
kalessin committed Jun 1, 2019
1 parent a7ac696 commit cf86042
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions hcf_backend/backend.py
Original file line number Diff line number Diff line change
Expand Up @@ -183,7 +183,7 @@ def _update_producer_new_links_stat(self):

def frontier_stop(self):
if self.producer:
n_flushed_links = self.producer.flush()
self.producer.flush()
self.producer.close()
self._update_producer_new_links_stat()

Expand Down Expand Up @@ -309,7 +309,7 @@ def _process_hcf_link(self, link):

slot = self.hcf_get_producer_slot(link)
if slot:
n_flushed_links = self.producer.add_request(slot, convert_from_bytes(hcf_request))
self.producer.add_request(slot, convert_from_bytes(hcf_request))

self.stats.inc_value(self._get_producer_stats_msg(slot, msg='total_links'))
self.stats.inc_value(self._get_producer_stats_msg(msg='total_links'))
Expand Down

0 comments on commit cf86042

Please sign in to comment.