(self, name: Key, index: int)
| 3868 | return dep.npartitions == 1 |
| 3869 | |
| 3870 | def _task(self, name: Key, index: int) -> Task: |
| 3871 | internal_tasks = [] |
| 3872 | for _expr in self.exprs: |
| 3873 | if self._broadcast_dep(_expr): |
| 3874 | subname = (_expr._name, 0) |
| 3875 | else: |
| 3876 | subname = (_expr._name, index) |
| 3877 | t = _expr._task(subname, subname[1]) |
| 3878 | |
| 3879 | assert t.key == subname |
| 3880 | internal_tasks.append(t) |
| 3881 | return Task.fuse(*internal_tasks, key=name) # type: ignore[return-value] |
| 3882 | |
| 3883 | @staticmethod |
| 3884 | def _execute_internal_graph(internal_tasks, dependencies, outkey): |
nothing calls this directly
no test coverage detected