@@ -53,22 +53,22 @@ def main(argv=sys.argv[1:]):
5353
5454 if args .list :
5555 response = client .list_runs () # how to include: page_token=args.page, page_size=args.page_size ?
56- json .dump (response . result () , sys .stdout , indent = 4 )
56+ json .dump (response , sys .stdout , indent = 4 )
5757 return 0
5858
5959 if args .log :
6060 response = client .get_run_log (run_id = args .log )
61- sys .stdout .write (response . result () ["workflow_log" ]["stderr" ])
61+ sys .stdout .write (response ["workflow_log" ]["stderr" ])
6262 return 0
6363
6464 if args .get :
6565 response = client .get_run_log (run_id = args .get )
66- json .dump (response . result () , sys .stdout , indent = 4 )
66+ json .dump (response , sys .stdout , indent = 4 )
6767 return 0
6868
6969 if args .info :
7070 response = client .get_service_info ()
71- json .dump (response . result () , sys .stdout , indent = 4 )
71+ json .dump (response , sys .stdout , indent = 4 )
7272 return 0
7373
7474 if not args .workflow_url :
@@ -95,14 +95,14 @@ def main(argv=sys.argv[1:]):
9595 sys .stdout .write (r ["run_id" ] + "\n " )
9696 exit (0 )
9797
98- r = client .get_run_status (run_id = r ["run_id" ]). result ()
98+ r = client .get_run_status (run_id = r ["run_id" ])
9999 while r ["state" ] in ("QUEUED" , "INITIALIZING" , "RUNNING" ):
100100 time .sleep (8 )
101- r = client .get_run_status (run_id = r ["run_id" ]). result ()
101+ r = client .get_run_status (run_id = r ["run_id" ])
102102
103103 logging .info ("State is %s" , r ["state" ])
104104
105- s = client .get_run_log (run_id = r ["run_id" ]). result ()
105+ s = client .get_run_log (run_id = r ["run_id" ])
106106
107107 try :
108108 # TODO: Only works with Arvados atm
0 commit comments