MCPcopy Create free account
hub / github.com/dask/dask / __call__

Method __call__

dask/_task_spec.py:753–768  ·  view source on GitHub ↗
(self, values=())

Source from the content-addressed store, hash-verified

751 return self._repr
752
753 def __call__(self, values=()):
754 self._verify_values(values)
755
756 def _eval(a):
757 if isinstance(a, GraphNode):
758 return a({k: values[k] for k in a.dependencies})
759 elif isinstance(a, TaskRef):
760 return values[a.key]
761 else:
762 return a
763
764 new_argspec = tuple(map(_eval, self.args))
765 if self.kwargs:
766 kwargs = {k: _eval(kw) for k, kw in self.kwargs.items()}
767 return self.func(*new_argspec, **kwargs)
768 return self.func(*new_argspec)
769
770 def __setstate__(self, state):
771 slots = self.__class__.get_all_slots()

Callers

nothing calls this directly

Calls 3

_verify_valuesMethod · 0.80
itemsMethod · 0.45
funcMethod · 0.45

Tested by

no test coverage detected