def __init__()

in oss-torch-connector/osstorchconnector/_oss_bucket_iterable.py [0:0]

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

    def __init__(self, client: OssClient, objects: Iterable[DataObject], preload: bool) -> Iterator[DataObject]:
        log.info("OssBucketObjectsIterator init")
        if preload:
            self._list_stream = iter(client.list_objects_from_uris_with_preload(objects))
        else:
            self._list_stream = iter(objects) # map does not need pass objects to client for now