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

Method _task

dask/dataframe/dask_expr/_expr.py:1810–1814  ·  view source on GitHub ↗
(self, name: Key, index: int)

Source from the content-addressed store, hash-verified

1808 return random_state_data(self.frame.npartitions, self.random_state)
1809
1810 def _task(self, name: Key, index: int) -> Task:
1811 args = [self._blockwise_arg(op, index) for op in self._args]
1812 kwargs = self._kwargs.copy()
1813 kwargs["random_state"] = self.random_state_data[index]
1814 return Task(name, self.operation, *args, **kwargs)
1815
1816
1817def _random_split_take(df, i, ndim):

Callers

nothing calls this directly

Calls 3

TaskClass · 0.90
_blockwise_argMethod · 0.45
copyMethod · 0.45

Tested by

no test coverage detected