

'''simple docstring'''





from typing import TYPE_CHECKING

from ...utils import (
    OptionalDependencyNotAvailable,
    _LazyModule,
    is_flax_available,
    is_tf_available,
    is_tokenizers_available,
    is_torch_available,
    is_vision_available,
)


UpperCamelCase_    						=       {
    """configuration_clip""": [
        """CLIP_PRETRAINED_CONFIG_ARCHIVE_MAP""",
        """CLIPConfig""",
        """CLIPOnnxConfig""",
        """CLIPTextConfig""",
        """CLIPVisionConfig""",
    ],
    """processing_clip""": ["""CLIPProcessor"""],
    """tokenization_clip""": ["""CLIPTokenizer"""],
}

try:
							if not is_tokenizers_available():
														raise OptionalDependencyNotAvailable()
except OptionalDependencyNotAvailable:
							pass
else:
							UpperCamelCase_    						=       ["""CLIPTokenizerFast"""]

try:
							if not is_vision_available():
														raise OptionalDependencyNotAvailable()
except OptionalDependencyNotAvailable:
							pass
else:
							UpperCamelCase_    						=       ["""CLIPFeatureExtractor"""]
							UpperCamelCase_    						=       ["""CLIPImageProcessor"""]

try:
							if not is_torch_available():
														raise OptionalDependencyNotAvailable()
except OptionalDependencyNotAvailable:
							pass
else:
							UpperCamelCase_    						=       [
							    """CLIP_PRETRAINED_MODEL_ARCHIVE_LIST""",
							    """CLIPModel""",
							    """CLIPPreTrainedModel""",
							    """CLIPTextModel""",
							    """CLIPTextModelWithProjection""",
							    """CLIPVisionModel""",
							    """CLIPVisionModelWithProjection""",
							]

try:
							if not is_tf_available():
														raise OptionalDependencyNotAvailable()
except OptionalDependencyNotAvailable:
							pass
else:
							UpperCamelCase_    						=       [
							    """TF_CLIP_PRETRAINED_MODEL_ARCHIVE_LIST""",
							    """TFCLIPModel""",
							    """TFCLIPPreTrainedModel""",
							    """TFCLIPTextModel""",
							    """TFCLIPVisionModel""",
							]

try:
							if not is_flax_available():
														raise OptionalDependencyNotAvailable()
except OptionalDependencyNotAvailable:
							pass
else:
							UpperCamelCase_    						=       [
							    """FlaxCLIPModel""",
							    """FlaxCLIPPreTrainedModel""",
							    """FlaxCLIPTextModel""",
							    """FlaxCLIPTextPreTrainedModel""",
							    """FlaxCLIPVisionModel""",
							    """FlaxCLIPVisionPreTrainedModel""",
							]


if TYPE_CHECKING:
							from .configuration_clip import (
							    CLIP_PRETRAINED_CONFIG_ARCHIVE_MAP,
							    CLIPConfig,
							    CLIPOnnxConfig,
							    CLIPTextConfig,
							    CLIPVisionConfig,
							)
							from .processing_clip import CLIPProcessor
							from .tokenization_clip import CLIPTokenizer

							try:
														if not is_tokenizers_available():
																					raise OptionalDependencyNotAvailable()
							except OptionalDependencyNotAvailable:
														pass
							else:
														from .tokenization_clip_fast import CLIPTokenizerFast

							try:
														if not is_vision_available():
																					raise OptionalDependencyNotAvailable()
							except OptionalDependencyNotAvailable:
														pass
							else:
														from .feature_extraction_clip import CLIPFeatureExtractor
														from .image_processing_clip import CLIPImageProcessor

							try:
														if not is_torch_available():
																					raise OptionalDependencyNotAvailable()
							except OptionalDependencyNotAvailable:
														pass
							else:
														from .modeling_clip import (
														    CLIP_PRETRAINED_MODEL_ARCHIVE_LIST,
														    CLIPModel,
														    CLIPPreTrainedModel,
														    CLIPTextModel,
														    CLIPTextModelWithProjection,
														    CLIPVisionModel,
														    CLIPVisionModelWithProjection,
														)

							try:
														if not is_tf_available():
																					raise OptionalDependencyNotAvailable()
							except OptionalDependencyNotAvailable:
														pass
							else:
														from .modeling_tf_clip import (
														    TF_CLIP_PRETRAINED_MODEL_ARCHIVE_LIST,
														    TFCLIPModel,
														    TFCLIPPreTrainedModel,
														    TFCLIPTextModel,
														    TFCLIPVisionModel,
														)

							try:
														if not is_flax_available():
																					raise OptionalDependencyNotAvailable()
							except OptionalDependencyNotAvailable:
														pass
							else:
														from .modeling_flax_clip import (
														    FlaxCLIPModel,
														    FlaxCLIPPreTrainedModel,
														    FlaxCLIPTextModel,
														    FlaxCLIPTextPreTrainedModel,
														    FlaxCLIPVisionModel,
														    FlaxCLIPVisionPreTrainedModel,
														)


else:
							import sys

							UpperCamelCase_    						=       _LazyModule(__name__, globals()["""__file__"""], _import_structure, module_spec=__spec__)













import importlib
import shutil
import threading
import warnings
from typing import List

import fsspec
import fsspec.asyn

from . import compression
from .hffilesystem import HfFileSystem


A__      :     int       =					importlib.util.find_spec('s3fs') is not None

if _has_safs:
							from .safilesystem import SaFileSystem  # noqa: F401

A__      :     List[compression.BaseCompressedFileFileSystem]       =					[
    compression.BzaFileSystem,
    compression.GzipFileSystem,
    compression.LzaFileSystem,
    compression.XzFileSystem,
    compression.ZstdFileSystem,
]

# Register custom filesystems
for fs_class in COMPRESSION_FILESYSTEMS + [HfFileSystem]:
							if fs_class.protocol in fsspec.registry and fsspec.registry[fs_class.protocol] is not fs_class:
														warnings.warn(F"A filesystem protocol was already set for {fs_class.protocol} and will be overwritten.")
							fsspec.register_implementation(fs_class.protocol, fs_class, clobber=True)






def     a     (		lowerCamelCase_							):






				'''simple docstring'''
				if "://" in dataset_path:
								lowercase__  					=     dataset_path.split('''://'''							)[1]
				return dataset_path






def     a     (		lowerCamelCase_							):






				'''simple docstring'''
				if fs is not None and fs.protocol != "file":
								return True
				else:
								return False






def     a     (		lowerCamelCase_						,  lowerCamelCase_						,  lowerCamelCase_							):






				'''simple docstring'''
				lowercase__  					=     not is_remote_filesystem(lowerCamelCase_							)
				if is_local:
								# LocalFileSystem.mv does copy + rm, it is more efficient to simply move a local directory
								shutil.move(fs._strip_protocol(lowerCamelCase_							)						,  fs._strip_protocol(lowerCamelCase_							)							)
				else:
								fs.mv(lowerCamelCase_						,  lowerCamelCase_						,  recursive=lowerCamelCase_							)






def     a     (		):






				'''simple docstring'''
				if hasattr(fsspec.asyn						,  '''reset_lock'''							):
								# for future fsspec>2022.05.0
								fsspec.asyn.reset_lock()
				else:
								lowercase__  					=     None
								lowercase__  					=     None
								lowercase__  					=     threading.Lock()




