Skip to content

Commit 91ae089

Browse files
committed
fixed task_def_from_dict
1 parent 2051071 commit 91ae089

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pydra/utils/general.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -636,7 +636,7 @@ def task_def_from_dict(task_def_dict: dict[str, ty.Any]) -> type["Task"]:
636636
dct = copy(task_def_dict)
637637
task_type = dct.pop("type")
638638
compose_module = importlib.import_module(f"pydra.compose.{task_type}")
639-
return compose_module.define(dct.pop("function"), **dct)
639+
return compose_module.define(dct.pop(compose_module.Task._executor_name), **dct)
640640

641641

642642
def _filter_defaults(atr: attrs.Attribute, value: ty.Any) -> bool:

0 commit comments

Comments
 (0)