






import importlib
import inspect
from functools import wraps
from typing import TYPE_CHECKING, Optional, Union

from .download.streaming_download_manager import (
    xbasename,
    xdirname,
    xet_parse,
    xexists,
    xgetsize,
    xglob,
    xgzip_open,
    xisdir,
    xisfile,
    xjoin,
    xlistdir,
    xnumpy_load,
    xopen,
    xpandas_read_csv,
    xpandas_read_excel,
    xPath,
    xrelpath,
    xsio_loadmat,
    xsplit,
    xsplitext,
    xwalk,
    xxml_dom_minidom_parse,
)
from .utils.logging import get_logger
from .utils.patching import patch_submodule
from .utils.py_utils import get_imports


A										=      get_logger(__name__)


if TYPE_CHECKING:
				from .builder import DatasetBuilder



def        _lowerCamelCase(      lowerCAmelCase__					:		Dict     ,     lowerCAmelCase__					:		Optional[Union[str, bool]] = None   ):





				'''simple docstring'''







				SCREAMING_SNAKE_CASE_ :						Optional[Any]    				= importlib.import_module(lowerCAmelCase__   )

				# TODO(QL): always update the module to add subsequent new authentication
				if hasattr(lowerCAmelCase__     ,     '_patched_for_streaming'   ) and module._patched_for_streaming:
								return

				def wrap_auth(lowerCAmelCase__					:		Tuple   ):
								@wraps(lowerCAmelCase__   )
								def wrapper(*lowerCAmelCase__					:		Any     ,     **lowerCAmelCase__					:		List[Any]   ):
												return function(*lowerCAmelCase__     ,     use_auth_token=lowerCAmelCase__     ,     **lowerCAmelCase__   )

								SCREAMING_SNAKE_CASE_ :						int    				= 'wrap_auth'
								return wrapper

				# open files in a streaming fashion
				patch_submodule(lowerCAmelCase__     ,     'open'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.listdir'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.walk'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'glob.glob'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				# allow to navigate in remote zip files
				patch_submodule(lowerCAmelCase__     ,     'os.path.join'     ,     lowerCAmelCase__   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.dirname'     ,     lowerCAmelCase__   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.basename'     ,     lowerCAmelCase__   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.relpath'     ,     lowerCAmelCase__   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.split'     ,     lowerCAmelCase__   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.splitext'     ,     lowerCAmelCase__   ).start()
				# allow checks on paths
				patch_submodule(lowerCAmelCase__     ,     'os.path.exists'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.isdir'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.isfile'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'os.path.getsize'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'pathlib.Path'     ,     lowerCAmelCase__   ).start()
				# file readers
				patch_submodule(lowerCAmelCase__     ,     'gzip.open'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'numpy.load'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'pandas.read_csv'     ,     wrap_auth(lowerCAmelCase__   )     ,     attrs=['__version__']   ).start()
				patch_submodule(lowerCAmelCase__     ,     'pandas.read_excel'     ,     wrap_auth(lowerCAmelCase__   )     ,     attrs=['__version__']   ).start()
				patch_submodule(lowerCAmelCase__     ,     'scipy.io.loadmat'     ,     wrap_auth(lowerCAmelCase__   )     ,     attrs=['__version__']   ).start()
				patch_submodule(lowerCAmelCase__     ,     'xml.etree.ElementTree.parse'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				patch_submodule(lowerCAmelCase__     ,     'xml.dom.minidom.parse'     ,     wrap_auth(lowerCAmelCase__   )   ).start()
				SCREAMING_SNAKE_CASE_ :						List[str]    				= True



def        _lowerCamelCase(      lowerCAmelCase__					:		"DatasetBuilder"   ):





				'''simple docstring'''







				extend_module_for_streaming(builder.__module__     ,     use_auth_token=builder.use_auth_token   )
				# if needed, we also have to extend additional internal imports (like wmt14 -> wmt_utils)
				if not builder.__module__.startswith('datasets.'   ):  # check that it's not a packaged builder like csv
								for imports in get_imports(inspect.getfile(builder.__class__   )   ):
												if imports[0] == "internal":
																SCREAMING_SNAKE_CASE_ :						Union[str, Any]    				= imports[1]
																SCREAMING_SNAKE_CASE_ :						Union[str, Any]    				= '.'.join(builder.__module__.split('.'   )[:-1] + [internal_import_name]   )
																extend_module_for_streaming(lowerCAmelCase__     ,     use_auth_token=builder.use_auth_token   )

    # builders can inherit from other builders that might use streaming functionality
    # (for example, ImageFolder and AudioFolder inherit from FolderBuilder which implements examples generation)
    # but these parents builders are not patched automatically as they are not instantiated, so we patch them here
				from .builder import DatasetBuilder

				SCREAMING_SNAKE_CASE_ :						Optional[int]    				= [
				    cls.__module__
				    for cls in type(lowerCAmelCase__   ).__mro__[1:]  # make sure it's not the same module we've already patched
				    if issubclass(cls     ,     lowerCAmelCase__   ) and cls.__module__ != DatasetBuilder.__module__
				]  # check it's not a standard builder from datasets.builder
				for module in parent_builder_modules:
								extend_module_for_streaming(lowerCAmelCase__     ,     use_auth_token=builder.use_auth_token   )







def        _lowerCamelCase(      lowerCAmelCase__					:		float     ,     lowerCAmelCase__					:		float     ,     lowerCAmelCase__					:		float   ):





				'''simple docstring'''







				if mass < 0:
								raise ValueError('The mass of the body cannot be negative'   )
				if radius <= 0:
								raise ValueError('The radius is always a positive non zero integer'   )
				return (mass * (velocity) ** 2) / radius


if __name__ == "__main__":
				import doctest

				doctest.testmod(verbose=True)