Skip to content
This repository has been archived by the owner on May 27, 2022. It is now read-only.

Commit

Permalink
Remove unnecessary variable
Browse files Browse the repository at this point in the history
  • Loading branch information
thekad committed Aug 6, 2012
1 parent aaeb91b commit 20853eb
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions tableslurp
Expand Up @@ -158,12 +158,10 @@ class DownloadHandler(object):
def _worker(self, idx, subset, event):
log.info('Thread #%d will process %d items' % (idx, len(subset),))
bucket = self._get_bucket()
cancelled = False
for fname in subset:
if event.is_set():
log.info('Thread #%d got cancelled' % (idx,))
cancelled = True
break
return
key = '%s/%s' % (self.prefix, fname,)
destfile = os.path.join(self.target, os.path.basename(fname))
download = False
Expand All @@ -189,8 +187,7 @@ class DownloadHandler(object):
log.debug(e)
log.warning('Failed to download `%s`' % (fname,))
continue
if not cancelled:
log.info('Thread #%d finished processing' % (idx,))
log.info('Thread #%d finished processing' % (idx,))

def run(self):
self._test_permissions()
Expand Down

0 comments on commit 20853eb

Please sign in to comment.