[ARVADOS] updated: 4b096c9ab1a9a457b2df2ac7309b340268741665

[git at public.curoverse.com]

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

       via  4b096c9ab1a9a457b2df2ac7309b340268741665 (commit)
      from  34a84410d6ce526dc626eb75a431ba7e0992d0c7 (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 4b096c9ab1a9a457b2df2ac7309b340268741665
Author: Bryan Cosca <bcosc at curoverse.com>
Date:   Fri Aug 7 11:40:49 2015 -0400

    6600: Added _add_task function with default num_retries=5 for one_task_per* functions to use for retrying

diff --git a/sdk/python/arvados/__init__.py b/sdk/python/arvados/__init__.py
index f75abd9..1245b5a 100644
--- a/sdk/python/arvados/__init__.py
+++ b/sdk/python/arvados/__init__.py
@@ -87,8 +87,8 @@ class JobTask(object):
 
 class job_setup:
     @retry_method
-    def _add_task(self, num_retries):
-	return self.num_retries
+    def _add_task(self, num_retries=5):
+        return
 
     @staticmethod
     def one_task_per_input_file(if_sequence=0, and_end_task=True, input_as_path=False, api_client=None):
@@ -115,11 +115,11 @@ class job_setup:
                         'input':task_input
                         }
                     }
-                api_client.job_tasks().create(body=new_task_attrs).execute()._add_task(num_retries=5)
+                api_client.job_tasks().create(body=new_task_attrs).execute()._add_task()
         if and_end_task:
             api_client.job_tasks().update(uuid=current_task()['uuid'],
                                        body={'success':True}
-                                       ).execute()
+                                       ).execute()._add_task()
             exit(0)
 
     @staticmethod
@@ -138,9 +138,9 @@ class job_setup:
                     'input':task_input
                     }
                 }
-            api('v1').job_tasks().create(body=new_task_attrs).execute()._add_task(num_retries=5)
+            api('v1').job_tasks().create(body=new_task_attrs).execute()._add_task()
         if and_end_task:
             api('v1').job_tasks().update(uuid=current_task()['uuid'],
                                        body={'success':True}
-                                       ).execute()
+                                       ).execute()._add_task()
             exit(0)

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


hooks/post-receive
--