@@ -53,22 +53,22 @@ def main(argv=sys.argv[1:]):
53
53
54
54
if args .list :
55
55
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 )
57
57
return 0
58
58
59
59
if args .log :
60
60
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" ])
62
62
return 0
63
63
64
64
if args .get :
65
65
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 )
67
67
return 0
68
68
69
69
if args .info :
70
70
response = client .get_service_info ()
71
- json .dump (response . result () , sys .stdout , indent = 4 )
71
+ json .dump (response , sys .stdout , indent = 4 )
72
72
return 0
73
73
74
74
if not args .workflow_url :
@@ -95,14 +95,14 @@ def main(argv=sys.argv[1:]):
95
95
sys .stdout .write (r ["run_id" ] + "\n " )
96
96
exit (0 )
97
97
98
- r = client .get_run_status (run_id = r ["run_id" ]). result ()
98
+ r = client .get_run_status (run_id = r ["run_id" ])
99
99
while r ["state" ] in ("QUEUED" , "INITIALIZING" , "RUNNING" ):
100
100
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" ])
102
102
103
103
logging .info ("State is %s" , r ["state" ])
104
104
105
- s = client .get_run_log (run_id = r ["run_id" ]). result ()
105
+ s = client .get_run_log (run_id = r ["run_id" ])
106
106
107
107
try :
108
108
# TODO: Only works with Arvados atm
0 commit comments