in oss-torch-connector/osstorchconnector/_oss_bucket_iterable.py [0:0]
def from_prefix(cls, oss_uri: str, client: OssClient, preload: bool = False):
if not oss_uri:
raise ValueError("oss_uri must be non-empty")
if not oss_uri.startswith("oss://"):
raise ValueError("only oss:// uri are supported")
return cls(client, oss_uri=oss_uri, preload=preload)