def __init__()

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

• 7 lines of code
• 2 McCabe index (conditional complexity)

    def __init__(self, client: OssClient, oss_uri: str, preload: bool):
        log.info("OssBucketPrefixIterator init")
        bucket, prefix = parse_oss_uri(oss_uri)
        if preload:
            self._list_stream = iter(client.list_objects_with_preload(bucket, prefix))
        else:
            self._list_stream = iter(client.list_objects(bucket, prefix))