def _partitioned_download()

in src/azstoragetorch/_client.py [0:0]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    def _partitioned_download(self, offset: int, length: int) -> bytes:
        futures = []
        for read_partition in self._get_partitions(
            offset, length, self._PARTITION_SIZE
        ):
            futures.append(
                self._get_executor().submit(
                    self._download_with_retries, *read_partition
                )
            )
        return b"".join(f.result() for f in futures)