@@ -72,14 +72,14 @@ def run_cwl_md5sum(cwl_input):
72
72
return os .path .join (output_dir , 'md5sum.txt' ), response ['workflow_id' ]
73
73
74
74
75
- def run_wdl_md5sum (cwl_input ):
75
+ def run_wdl_md5sum (wdl_input ):
76
76
"""Pass a local md5sum wdl to the wes-service server, and return the path of the output file that was created."""
77
77
endpoint = 'http://localhost:8080/ga4gh/wes/v1/workflows'
78
78
params = '{"ga4ghMd5.inputFile": "' + os .path .abspath ('testdata/md5sum.input' ) + '"}'
79
79
parts = [("workflow_params" , params ),
80
80
("workflow_type" , "WDL" ),
81
81
("workflow_type_version" , "v1.0" ),
82
- ("workflow_url" , cwl_input )]
82
+ ("workflow_url" , wdl_input )]
83
83
response = requests .post (endpoint , files = parts ).json ()
84
84
output_dir = os .path .abspath (os .path .join ('workflows' , response ['workflow_id' ], 'outdir' ))
85
85
return os .path .join (output_dir , 'md5sum.txt' ), response ['workflow_id' ]
@@ -139,8 +139,8 @@ def setUp(self):
139
139
140
140
def test_wdl_md5sum (self ):
141
141
"""Pass a local md5sum cwl to the wes-service server, and check for the correct output."""
142
- cwl_local_path = os .path .abspath ('testdata/md5sum.wdl' )
143
- output_filepath , _ = run_wdl_md5sum (cwl_input = cwl_local_path )
142
+ wdl_local_path = os .path .abspath ('testdata/md5sum.wdl' )
143
+ output_filepath , _ = run_wdl_md5sum (wdl_input = wdl_local_path )
144
144
145
145
self .assertTrue (check_for_file (output_filepath ), 'Output file was not found: ' + str (output_filepath ))
146
146
0 commit comments