Skip to content

Commit ef86a10

Browse files
Adds more updates to wfchef
1 parent cdfed55 commit ef86a10

3 files changed

Lines changed: 3 additions & 2 deletions

File tree

wfcommons/common/task.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ def as_dict(self) -> Dict:
126126

127127
task_obj = {
128128
'name': self.name,
129-
'type': self.type.value,
129+
# 'type': self.type.value,
130130
'command': {},
131131
'parents': [],
132132
'children': [],

wfcommons/wfchef/chef.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -231,6 +231,7 @@ def uninstall_recipe(wf_name: str,
231231

232232
# Removing the recipe directory
233233
if dst.exists():
234+
print(f"Removing {dst}")
234235
subprocess.Popen(["rm", "-rf", str(dst)]).wait()
235236

236237
# Find setup.py, clean it and reinstall it

wfcommons/wfgen/abstract_recipe.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ def _generate_task(self, task_name: str, task_id: str) -> Task:
151151
name=task_id,
152152
task_id='0{}'.format(task_id.split('_0')[1]),
153153
category=task_name,
154-
task_type=TaskType.COMPUTE,
154+
# task_type=TaskType.COMPUTE,
155155
runtime=runtime,
156156
machine=None,
157157
program=task_name,

0 commit comments

Comments
 (0)