[ARVADOS] updated: 86f04235021d84afa0d28d105111422e0dd15738
Git user
git at public.curoverse.com
Fri Nov 25 18:22:52 EST 2016
Summary of changes:
sdk/python/arvados/keep.py | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
via 86f04235021d84afa0d28d105111422e0dd15738 (commit)
from 7c2b38632ae2af8a2f0f5c8fa2e55523220a3335 (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit 86f04235021d84afa0d28d105111422e0dd15738
Author: Tom Clegg <tom at curoverse.com>
Date: Fri Nov 25 18:21:51 2016 -0500
10586: Suppress stack traces for expected http errors.
diff --git a/sdk/python/arvados/keep.py b/sdk/python/arvados/keep.py
index 776c9b2..f318ea7 100644
--- a/sdk/python/arvados/keep.py
+++ b/sdk/python/arvados/keep.py
@@ -576,6 +576,8 @@ class KeepClient(object):
class KeepWriterThread(threading.Thread):
+ TaskFailed = RuntimeError()
+
def __init__(self, queue, data, data_hash, timeout=None):
super(KeepClient.KeepWriterThread, self).__init__()
self.timeout = timeout
@@ -593,7 +595,8 @@ class KeepClient(object):
try:
locator, copies = self.do_task(service, service_root)
except Exception as e:
- _logger.exception("Exception in KeepWriterThread")
+ if e != self.TaskFailed:
+ _logger.exception("Exception in KeepWriterThread")
self.queue.write_fail(service)
else:
self.queue.write_success(locator, copies)
@@ -614,7 +617,7 @@ class KeepClient(object):
self.data_hash,
result['status_code'],
result['body'])
- raise RuntimeError()
+ raise self.TaskFailed
_logger.debug("KeepWriterThread %s succeeded %s+%i %s",
str(threading.current_thread()),
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list