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

Method _task

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

Source from the content-addressed store, hash-verified

1712 return self.frame._meta
1713
1714 def _task(self, name: Key, index: int) -> Task:
1715 args = [self._blockwise_arg(op, index) for op in self._args]
1716 args = args + [
1717 index,
1718 self.divisions[index],
1719 self.divisions[index + 1],
1720 index == (self.npartitions - 1),
1721 ]
1722 return Task(name, self.operation, *args)
1723
1724
1725class Abs(Elemwise):

Callers

nothing calls this directly

Calls 2

TaskClass · 0.90
_blockwise_argMethod · 0.45

Tested by

no test coverage detected