(self, name: Key, index: int)
| 138 | return tuple(new_divisions) |
| 139 | |
| 140 | def _task(self, name: Key, index: int) -> Task: |
| 141 | expr = self.operand("_expr") |
| 142 | bucket = self._fusion_buckets[index] |
| 143 | # FIXME: This will likely require a wrapper |
| 144 | return Task( |
| 145 | name, |
| 146 | methods.concat, |
| 147 | List(*(expr._filtered_task(name, i) for i in bucket)), |
| 148 | _data_producer=True, |
| 149 | ) |
| 150 | |
| 151 | @property |
| 152 | def _fusion_buckets(self): |
nothing calls this directly
no test coverage detected