(self, name: Key, index: int)
| 3824 | return dep.npartitions == 1 |
| 3825 | |
| 3826 | def _task(self, name: Key, index: int) -> Task: |
| 3827 | internal_tasks = [] |
| 3828 | for _expr in self.exprs: |
| 3829 | if self._broadcast_dep(_expr): |
| 3830 | subname = (_expr._name, 0) |
| 3831 | else: |
| 3832 | subname = (_expr._name, index) |
| 3833 | t = _expr._task(subname, subname[1]) |
| 3834 | |
| 3835 | assert t.key == subname |
| 3836 | internal_tasks.append(t) |
| 3837 | return Task.fuse(*internal_tasks, key=name) # type: ignore |
| 3838 | |
| 3839 | @staticmethod |
| 3840 | def _execute_internal_graph(internal_tasks, dependencies, outkey): |
nothing calls this directly
no test coverage detected