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

Method _task

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

Source from the content-addressed store, hash-verified

1805 return random_state_data(self.frame.npartitions, self.random_state)
1806
1807 def _task(self, name: Key, index: int) -> Task:
1808 args = [self._blockwise_arg(op, index) for op in self._args]
1809 kwargs = self._kwargs.copy()
1810 kwargs["random_state"] = self.random_state_data[index]
1811 return Task(name, self.operation, *args, **kwargs)
1812
1813
1814def _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