Produce the task for a specific partition Parameters ---------- index: Partition index for this task. Returns ------- task: tuple
(self, name: Key, index: int)
| 620 | return arg |
| 621 | |
| 622 | def _task(self, name: Key, index: int) -> Task: |
| 623 | """Produce the task for a specific partition |
| 624 | |
| 625 | Parameters |
| 626 | ---------- |
| 627 | index: |
| 628 | Partition index for this task. |
| 629 | |
| 630 | Returns |
| 631 | ------- |
| 632 | task: tuple |
| 633 | """ |
| 634 | args = [self._blockwise_arg(op, index) for op in self._args] |
| 635 | if self._kwargs: |
| 636 | return Task(name, self.operation, *args, **self._kwargs) # type: ignore[arg-type] |
| 637 | else: |
| 638 | return Task(name, self.operation, *args) # type: ignore[arg-type] |
| 639 | |
| 640 | def _simplify_up(self, parent, dependents): |
| 641 | if self._projection_passthrough and isinstance(parent, Projection): |
nothing calls this directly
no test coverage detected