Skip to content

Commit

Permalink
Correct invalid function call
Browse files Browse the repository at this point in the history
Remove the call to the "lookup" function, which doesn't exist.
  • Loading branch information
rmarianski committed Jan 8, 2018
1 parent 8cad0a5 commit 7fc2471
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions tilequeue/queue/sqs.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ def extend(self, handle, now=None):
else:
state = VisibilityState(now, self.extend_secs)
self.handle_state_map[handle] = state
return state

def done(self, handle):
try:
Expand Down Expand Up @@ -143,7 +144,7 @@ def job_done(self, handle):

def job_progress(self, handle):
if self.visibility_mgr.should_extend(handle):
self.visibility_mgr.extend(handle)
visibility_state = self.visibility_mgr.extend(handle)

try:
self.sqs_client.change_message_visibility(
Expand All @@ -152,7 +153,6 @@ def job_progress(self, handle):
VisibilityTimeout=self.visibility_mgr.extend_secs,
)
except Exception as e:
visibility_state = self.visibility_mgr.lookup(handle)
err_details = dict(
visibility=dict(
last=visibility_state.last.isoformat(),
Expand Down

0 comments on commit 7fc2471

Please sign in to comment.