in oss-torch-connector/osstorchconnector/_oss_bucket_iterable.py [0:0]
def __init__(self, client: OssClient, *,
oss_uri: str = None,
object_uris: Iterable[str] = None,
preload: bool = False,
manifest_file_path: str = None,
manifest_parser: Callable[[io.IOBase], Iterable[Tuple[str, str]]] = None,
oss_base_uri: str = None):
log.info("OssBucketIterable init")
self._client = client
self._oss_uri = oss_uri
self._object_uris = object_uris
self._preload = preload
self._manifest_file_path = manifest_file_path
self._manifest_parser = manifest_parser
self._oss_base_uri = oss_base_uri
self._data_objects: Iterable[DataObject] = None