[ARVADOS] updated: 40ba58c70a32e14de92e46d5d74a85d0a9642ee8

git at public.curoverse.com git at public.curoverse.com
Fri Aug 14 10:56:16 EDT 2015


Summary of changes:
 sdk/python/arvados/__init__.py | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

       via  40ba58c70a32e14de92e46d5d74a85d0a9642ee8 (commit)
      from  5e8544101a1a82f7c70b15cff94d83ff35e30063 (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 40ba58c70a32e14de92e46d5d74a85d0a9642ee8
Author: Bryan Cosca <bcosc at curoverse.com>
Date:   Fri Aug 14 10:56:12 2015 -0400

    flailing at 10:55am 8.14.15

diff --git a/sdk/python/arvados/__init__.py b/sdk/python/arvados/__init__.py
index 8b5ffcb..ec065d9 100644
--- a/sdk/python/arvados/__init__.py
+++ b/sdk/python/arvados/__init__.py
@@ -39,16 +39,19 @@ logger.addHandler(log_handler)
 logger.setLevel(logging.DEBUG if config.get('ARVADOS_DEBUG')
                 else logging.WARNING)
 
- at retry_method
-def task_set_output(self,s,num_retries=None,api_client=None):
+def __init__(self,api_client=None,num_retries=None):
+    self.num_retries = num_retries if num_retries is not None else 5
+
+#@retry_method
+def task_set_output(self,s,api_client=None):
 
     if not api_client:
         api_client = api('v1')
 
-    if not num_retries:
-        num_retries=5
+    #if not self.num_retries:
+    #    self.num_retries=5
 
-    output_retry_loop = RetryLoop(num_retries=num_retries, backoff_start=1)
+    output_retry_loop = RetryLoop(num_retries=2, backoff_start=1)
     for tries_left in output_retry_loop:
 	try:
 	    api_client.job_tasks().update(uuid=self['uuid'],
@@ -56,7 +59,7 @@ def task_set_output(self,s,num_retries=None,api_client=None):
             					'output':s,
 				            	'success':True,
 				            	'progress':1.0
-			                 	}).execute()
+			                 	}).execute(num_retries=num_retries)
 	except TemporaryError as error:
 	    logger.debug("Error in task_set_output api call: {} ({} tries left)".format(error,tries_left))
 	else:

-----------------------------------------------------------------------


hooks/post-receive
-- 




More information about the arvados-commits mailing list