Use body={...} instead of object_type=json.dumps({...})

diff --git a/crunch_scripts/pgp-survey-import b/crunch_scripts/pgp-survey-import
index 8d9b3d58552f97189e02694c39150e2b1a87a6ab..811dd118729f1935e6310495687c9424724bc83c 100755 (executable)
--- a/crunch_scripts/pgp-survey-import
+++ b/crunch_scripts/pgp-survey-import
@@ -57,15 +57,15 @@ for input_file in arvados.CollectionReader(this_job_input).all_files():
                 human_uuid = huID_links_match[0]['head_uuid']
             else:
                 human = arvados.service.humans().create(
-                    human=json.dumps({})
+                    body={}
                     ).execute()
                 huID_link = arvados.service.links().create(
-                    link=json.dumps({
-                            'link_class':'identifier',
-                            'name':words[0],
-                            'head_kind':'arvados#human',
-                            'head_uuid':human['uuid']
-                            })
+                    body={
+                        'link_class':'identifier',
+                        'name':words[0],
+                        'head_kind':'arvados#human',
+                        'head_uuid':human['uuid']
+                        }
                     ).execute()
                 human_uuid = human['uuid']
             human_trait = {}
@@ -89,7 +89,7 @@ for input_file in arvados.CollectionReader(this_job_input).all_files():
                         trait_link['properties']['value'] = trait_value
                         arvados.service.links().update(
                             uuid=trait_link['uuid'],
-                            link=json.dumps({'properties':trait_link['properties']})
+                            body={'properties':trait_link['properties']}
                             ).execute()
                     out.write(",\n")
                     out.write(json.dumps(trait_link))
@@ -107,7 +107,7 @@ for input_file in arvados.CollectionReader(this_job_input).all_files():
                         'properties': { 'value': trait_value }
                         }
                     arvados.service.links().create(
-                        link=json.dumps(trait_link)
+                        body=trait_link
                         ).execute()
                     out.write(",\n")
                     out.write(json.dumps(trait_link))

diff --git a/doc/user/tutorial-trait-search.textile b/doc/user/tutorial-trait-search.textile
index 92646a73648e49ff56d4f79820c676fe566fb086..0c93ef614315a717f720d0d494d1dec38d62602f 100644 (file)
--- a/doc/user/tutorial-trait-search.textile
+++ b/doc/user/tutorial-trait-search.textile
@@ -190,11 +190,11 @@ Look for variant rs1126809 in each of the "var" files (these contain variant cal
 job = {}
 for c in collections:
   if [] != filter(lambda f: re.search('^var-.*\.tsv\.bz2', f[1]), c['files']):
-    job[c['uuid']] = arvados.service.jobs().create(job=json.dumps({
+    job[c['uuid']] = arvados.service.jobs().create(body={
       'script': 'grep',
       'script_parameters': {'input': c['uuid'], 'pattern': "rs1126809\\b"},
       'script_version': 'e7aeb42'
-    })).execute()
+    }).execute()
     print "%s %s" % (pgpid[c['uuid']], job[c['uuid']]['uuid'])
 
 </pre>

diff --git a/sdk/python/arvados.py b/sdk/python/arvados.py
index f4fe0707865c22e37cd6e4eab317d31723d13372..7af06096702ea41a3a0109325e1ab968b9bc9271 100644 (file)
--- a/sdk/python/arvados.py
+++ b/sdk/python/arvados.py
@@ -64,11 +64,11 @@ service = build("arvados", "v1", http=http, discoveryServiceUrl=url)
 
 def task_set_output(self,s):
     service.job_tasks().update(uuid=self['uuid'],
-                               job_task=json.dumps({
-                'output':s,
-                'success':True,
-                'progress':1.0
-                })).execute()
+                               body={
+            'output':s,
+            'success':True,
+            'progress':1.0
+            }).execute()
 
 _current_task = None
 def current_task():
@@ -121,10 +121,10 @@ class job_setup:
                         'input':task_input
                         }
                     }
-                service.job_tasks().create(job_task=json.dumps(new_task_attrs)).execute()
+                service.job_tasks().create(body=new_task_attrs).execute()
         if and_end_task:
             service.job_tasks().update(uuid=current_task()['uuid'],
-                                       job_task=json.dumps({'success':True})
+                                       body={'success':True}
                                        ).execute()
             exit(0)
 
@@ -144,10 +144,10 @@ class job_setup:
                     'input':task_input
                     }
                 }
-            service.job_tasks().create(job_task=json.dumps(new_task_attrs)).execute()
+            service.job_tasks().create(body=new_task_attrs).execute()
         if and_end_task:
             service.job_tasks().update(uuid=current_task()['uuid'],
-                                       job_task=json.dumps({'success':True})
+                                       body={'success':True}
                                        ).execute()
             exit(0)