diff --git a/hamilton/experimental/h_dask.py b/hamilton/experimental/h_dask.py index 811c01c44..e4ea4590e 100644 --- a/hamilton/experimental/h_dask.py +++ b/hamilton/experimental/h_dask.py @@ -113,7 +113,7 @@ def execute_node(self, node: node.Node, kwargs: typing.Dict[str, typing.Any]) -> :param kwargs: the arguments that should be passed to it. :return: returns a dask delayed object. """ - return delayed(node.callable)(**kwargs) + return delayed(node.callable, name=node.name)(**kwargs) def build_result(self, **outputs: typing.Dict[str, typing.Any]) -> typing.Any: """Builds the result and brings it back to this running process.