(self, source, target, region=None)
| 397 | self.lock = lock |
| 398 | |
| 399 | def add(self, source, target, region=None): |
| 400 | if is_chunked_array(source): |
| 401 | self.sources.append(source) |
| 402 | self.targets.append(target) |
| 403 | self.regions.append(region) |
| 404 | elif region: |
| 405 | target[region] = source |
| 406 | else: |
| 407 | target[...] = source |
| 408 | |
| 409 | def sync(self, compute=True, chunkmanager_store_kwargs=None): |
| 410 | if self.sources: |
no test coverage detected