get_updates: Replace "failures" with the new dont_block option.
(imported from commit 2b4ecb35c4f14b6c408323662ef6f39c6485c62d)
This commit is contained in:
parent
13ebd229c1
commit
a644e4bc41
|
@ -63,8 +63,6 @@ class HumbugAPI(object):
|
||||||
if not (isinstance(val, str) or isinstance(val, unicode)):
|
if not (isinstance(val, str) or isinstance(val, unicode)):
|
||||||
request[key] = simplejson.dumps(val)
|
request[key] = simplejson.dumps(val)
|
||||||
|
|
||||||
request["failures"] = 0
|
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
res = requests.post(urlparse.urljoin(self.base_url, url), data=request,
|
res = requests.post(urlparse.urljoin(self.base_url, url), data=request,
|
||||||
|
@ -76,7 +74,7 @@ class HumbugAPI(object):
|
||||||
if not had_error_retry:
|
if not had_error_retry:
|
||||||
sys.stdout.write("connection error %s -- retrying." % (res.status_code,))
|
sys.stdout.write("connection error %s -- retrying." % (res.status_code,))
|
||||||
had_error_retry = True
|
had_error_retry = True
|
||||||
request["failures"] += 1
|
request["dont_block"] = simplejson.dumps(True)
|
||||||
else:
|
else:
|
||||||
sys.stdout.write(".")
|
sys.stdout.write(".")
|
||||||
sys.stdout.flush()
|
sys.stdout.flush()
|
||||||
|
@ -102,7 +100,7 @@ class HumbugAPI(object):
|
||||||
if not had_error_retry:
|
if not had_error_retry:
|
||||||
sys.stdout.write("connection error -- retrying.")
|
sys.stdout.write("connection error -- retrying.")
|
||||||
had_error_retry = True
|
had_error_retry = True
|
||||||
request["failures"] += 1
|
request["dont_block"] = simplejson.dumps(True)
|
||||||
else:
|
else:
|
||||||
sys.stdout.write(".")
|
sys.stdout.write(".")
|
||||||
sys.stdout.flush()
|
sys.stdout.flush()
|
||||||
|
|
Loading…
Reference in a new issue