We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 15db281 commit 89c2eaeCopy full SHA for 89c2eae
1 file changed
workflowhub/trace/logs/pegasus.py
@@ -123,10 +123,12 @@ def _parse_braindump(self):
123
124
def _parse_workflow(self):
125
"""Parse the Workflow file."""
126
- workflow_file = '{}/workflow.yml'.format(self.submit_dir)
+ workflows_file_list = self._fetch_all_files('yml', '*workflow')
127
128
- if not os.path.exists(workflow_file):
129
- raise OSError('Unable to find workflow file: {}'.format(workflow_file))
+ if len(workflows_file_list) < 1:
+ raise OSError('Unable to find workflow file.')
130
+
131
+ workflow_file = workflows_file_list[0]
132
133
with open(workflow_file) as f:
134
data = yaml.load(f, Loader=yaml.SafeLoader)
0 commit comments