@@ -60,7 +60,7 @@ def test_multipart_upload(self):
60
60
61
61
def run_md5sum (cwl_input ):
62
62
"""Pass a local md5sum cwl to the wes-service server, and return the path of the output file that was created."""
63
- endpoint = 'http://localhost:8080/ga4gh/wes/v1/workflows '
63
+ endpoint = 'http://localhost:8080/ga4gh/wes/v1/runs '
64
64
params = {'output_file' : {'path' : '/tmp/md5sum.txt' , 'class' : 'File' },
65
65
'input_file' : {'path' : '../../testdata/md5sum.input' , 'class' : 'File' }}
66
66
@@ -71,12 +71,12 @@ def run_md5sum(cwl_input):
71
71
else :
72
72
parts .append (("workflow_url" , cwl_input ))
73
73
response = requests .post (endpoint , files = parts ).json ()
74
- output_dir = os .path .abspath (os .path .join ('workflows' , response ['workflow_id ' ], 'outdir' ))
75
- return os .path .join (output_dir , 'md5sum.txt' ), response ['workflow_id ' ]
74
+ output_dir = os .path .abspath (os .path .join ('workflows' , response ['run_id ' ], 'outdir' ))
75
+ return os .path .join (output_dir , 'md5sum.txt' ), response ['run_id ' ]
76
76
77
77
78
78
def get_log_request (run_id ):
79
- endpoint = 'http://localhost:8080/ga4gh/wes/v1/workflows /{}' .format (run_id )
79
+ endpoint = 'http://localhost:8080/ga4gh/wes/v1/runs /{}' .format (run_id )
80
80
return requests .get (endpoint ).json ()
81
81
82
82
0 commit comments