





from dataclasses import dataclass
from typing import Optional, Tuple, Union

import torch
import torch.nn as nn

from ..configuration_utils import ConfigMixin, register_to_config
from ..utils import BaseOutput
from .embeddings import GaussianFourierProjection, TimestepEmbedding, Timesteps
from .modeling_utils import ModelMixin
from .unet_ad_blocks import get_down_block, get_mid_block, get_out_block, get_up_block

@dataclass
class    lowerCAmelCase							(					__UpperCamelCase			):
 UpperCAmelCase__													=		42


class    lowerCAmelCase							(					__UpperCamelCase,  __UpperCamelCase			):
 @register_to_config
 def __init__(      self  :      List[str]			,     UpperCAmelCase  :      int = 65536			,     UpperCAmelCase  :      Optional[int] = None			,     UpperCAmelCase  :      int = 2			,     UpperCAmelCase  :      int = 2			,     UpperCAmelCase  :      int = 0			,     UpperCAmelCase  :      str = "fourier"			,     UpperCAmelCase  :      bool = True			,     UpperCAmelCase  :      bool = False			,     UpperCAmelCase  :      float = 0.0			,     UpperCAmelCase  :      Tuple[str] = ("DownBlock1DNoSkip", "DownBlock1D", "AttnDownBlock1D")			,     UpperCAmelCase  :      Tuple[str] = ("AttnUpBlock1D", "UpBlock1D", "UpBlock1DNoSkip")			,     UpperCAmelCase  :      Tuple[str] = "UNetMidBlock1D"			,     UpperCAmelCase  :      str = None			,     UpperCAmelCase  :      Tuple[int] = (32, 32, 64)			,     UpperCAmelCase  :      str = None			,     UpperCAmelCase  :      int = 8			,     UpperCAmelCase  :      int = 1			,     UpperCAmelCase  :      bool = False			,     )			->	List[Any]:
     super().__init__()
     lowerCamelCase__    :      Optional[int]					 =		sample_size

     # time
     if time_embedding_type == "fourier":
         lowerCamelCase__    :      Optional[Any]					 =		GaussianFourierProjection(
             embedding_size=8			,     set_W_to_weight=UpperCAmelCase			,     log=UpperCAmelCase			,     flip_sin_to_cos=UpperCAmelCase	)
         lowerCamelCase__    :      Any					 =		2 * block_out_channels[0]
     elif time_embedding_type == "positional":
         lowerCamelCase__    :      List[Any]					 =		Timesteps(
             block_out_channels[0]			,     flip_sin_to_cos=UpperCAmelCase			,     downscale_freq_shift=UpperCAmelCase	)
         lowerCamelCase__    :      Dict					 =		block_out_channels[0]

     if use_timestep_embedding:
         lowerCamelCase__    :      str					 =		block_out_channels[0] * 4
         lowerCamelCase__    :      List[Any]					 =		TimestepEmbedding(
             in_channels=UpperCAmelCase			,     time_embed_dim=UpperCAmelCase			,     act_fn=UpperCAmelCase			,     out_dim=block_out_channels[0]			,     )

     lowerCamelCase__    :      Any					 =		nn.ModuleList([]	)
     lowerCamelCase__    :      Tuple					 =		None
     lowerCamelCase__    :      List[str]					 =		nn.ModuleList([]	)
     lowerCamelCase__    :      Optional[int]					 =		None

     # down
     lowerCamelCase__    :      Optional[int]					 =		in_channels
     for i, down_block_type in enumerate(UpperCAmelCase	):
         lowerCamelCase__    :      Union[str, Any]					 =		output_channel
         lowerCamelCase__    :      Tuple					 =		block_out_channels[i]

         if i == 0:
             input_channel += extra_in_channels

         lowerCamelCase__    :      Union[str, Any]					 =		i == len(UpperCAmelCase	) - 1

         lowerCamelCase__    :      Optional[int]					 =		get_down_block(
             UpperCAmelCase			,     num_layers=UpperCAmelCase			,     in_channels=UpperCAmelCase			,     out_channels=UpperCAmelCase			,     temb_channels=block_out_channels[0]			,     add_downsample=not is_final_block or downsample_each_block			,     )
         self.down_blocks.append(UpperCAmelCase	)

     # mid
     lowerCamelCase__    :      Optional[int]					 =		get_mid_block(
         UpperCAmelCase			,     in_channels=block_out_channels[-1]			,     mid_channels=block_out_channels[-1]			,     out_channels=block_out_channels[-1]			,     embed_dim=block_out_channels[0]			,     num_layers=UpperCAmelCase			,     add_downsample=UpperCAmelCase			,     )

     # up
     lowerCamelCase__    :      Optional[int]					 =		list(reversed(UpperCAmelCase	)	)
     lowerCamelCase__    :      Optional[int]					 =		reversed_block_out_channels[0]
     if out_block_type is None:
         lowerCamelCase__    :      List[str]					 =		out_channels
     else:
         lowerCamelCase__    :      Any					 =		block_out_channels[0]

     for i, up_block_type in enumerate(UpperCAmelCase	):
         lowerCamelCase__    :      Tuple					 =		output_channel
         lowerCamelCase__    :      Union[str, Any]					 =		(
             reversed_block_out_channels[i + 1] if i < len(UpperCAmelCase	) - 1 else final_upsample_channels
         )

         lowerCamelCase__    :      List[str]					 =		i == len(UpperCAmelCase	) - 1

         lowerCamelCase__    :      Dict					 =		get_up_block(
             UpperCAmelCase			,     num_layers=UpperCAmelCase			,     in_channels=UpperCAmelCase			,     out_channels=UpperCAmelCase			,     temb_channels=block_out_channels[0]			,     add_upsample=not is_final_block			,     )
         self.up_blocks.append(UpperCAmelCase	)
         lowerCamelCase__    :      int					 =		output_channel

     # out
     lowerCamelCase__    :      int					 =		norm_num_groups if norm_num_groups is not None else min(block_out_channels[0] // 4			,     32	)
     lowerCamelCase__    :      List[Any]					 =		get_out_block(
         out_block_type=UpperCAmelCase			,     num_groups_out=UpperCAmelCase			,     embed_dim=block_out_channels[0]			,     out_channels=UpperCAmelCase			,     act_fn=UpperCAmelCase			,     fc_dim=block_out_channels[-1] // 4			,     )







 def      A_	(      self  :      List[Any]			,     UpperCAmelCase  :      torch.FloatTensor			,     UpperCAmelCase  :      Union[torch.Tensor, float, int]			,     UpperCAmelCase  :      bool = True			,     )			->	Union[UNetaDOutput, Tuple]:
     lowerCamelCase__    :      Optional[Any]					 =		timestep
     if not torch.is_tensor(UpperCAmelCase	):
         lowerCamelCase__    :      Optional[int]					 =		torch.tensor([timesteps]			,     dtype=torch.long			,     device=sample.device	)
     elif torch.is_tensor(UpperCAmelCase	) and len(timesteps.shape	) == 0:
         lowerCamelCase__    :      List[str]					 =		timesteps[None].to(sample.device	)

     lowerCamelCase__    :      Optional[int]					 =		self.time_proj(UpperCAmelCase	)
     if self.config.use_timestep_embedding:
         lowerCamelCase__    :      str					 =		self.time_mlp(UpperCAmelCase	)
     else:
         lowerCamelCase__    :      List[str]					 =		timestep_embed[..., None]
         lowerCamelCase__    :      str					 =		timestep_embed.repeat([1, 1, sample.shape[2]]	).to(sample.dtype	)
         lowerCamelCase__    :      str					 =		timestep_embed.broadcast_to((sample.shape[:1] + timestep_embed.shape[1:])	)

     # 2. down
     lowerCamelCase__    :      str					 =		()
     for downsample_block in self.down_blocks:
         lowerCamelCase__ ,							lowerCamelCase__    :      Union[str, Any]					 =		downsample_block(hidden_states=UpperCAmelCase			,     temb=UpperCAmelCase	)
         down_block_res_samples += res_samples

     # 3. mid
     if self.mid_block:
         lowerCamelCase__    :      Optional[Any]					 =		self.mid_block(UpperCAmelCase			,     UpperCAmelCase	)

     # 4. up
     for i, upsample_block in enumerate(self.up_blocks	):
         lowerCamelCase__    :      Dict					 =		down_block_res_samples[-1:]
         lowerCamelCase__    :      Optional[Any]					 =		down_block_res_samples[:-1]
         lowerCamelCase__    :      Any					 =		upsample_block(UpperCAmelCase			,     res_hidden_states_tuple=UpperCAmelCase			,     temb=UpperCAmelCase	)

     # 5. post-process
     if self.out_block:
         lowerCamelCase__    :      Any					 =		self.out_block(UpperCAmelCase			,     UpperCAmelCase	)

     if not return_dict:
         return (sample,)

     return UNetaDOutput(sample=UpperCAmelCase	)







from . import __version__

# Backward compatibility imports, to make sure all those objects can be found in file_utils
from .utils import (
    CLOUDFRONT_DISTRIB_PREFIX,
    CONFIG_NAME,
    DISABLE_TELEMETRY,
    DUMMY_INPUTS,
    DUMMY_MASK,
    ENV_VARS_TRUE_AND_AUTO_VALUES,
    ENV_VARS_TRUE_VALUES,
    FEATURE_EXTRACTOR_NAME,
    FLAX_WEIGHTS_NAME,
    HF_MODULES_CACHE,
    HUGGINGFACE_CO_PREFIX,
    HUGGINGFACE_CO_RESOLVE_ENDPOINT,
    MODEL_CARD_NAME,
    MULTIPLE_CHOICE_DUMMY_INPUTS,
    PYTORCH_PRETRAINED_BERT_CACHE,
    PYTORCH_TRANSFORMERS_CACHE,
    S3_BUCKET_PREFIX,
    SENTENCEPIECE_UNDERLINE,
    SPIECE_UNDERLINE,
    TF2_WEIGHTS_NAME,
    TF_WEIGHTS_NAME,
    TORCH_FX_REQUIRED_VERSION,
    TRANSFORMERS_CACHE,
    TRANSFORMERS_DYNAMIC_MODULE_NAME,
    USE_JAX,
    USE_TF,
    USE_TORCH,
    WEIGHTS_INDEX_NAME,
    WEIGHTS_NAME,
    ContextManagers,
    DummyObject,
    EntryNotFoundError,
    ExplicitEnum,
    ModelOutput,
    PaddingStrategy,
    PushToHubMixin,
    RepositoryNotFoundError,
    RevisionNotFoundError,
    TensorType,
    _LazyModule,
    add_code_sample_docstrings,
    add_end_docstrings,
    add_start_docstrings,
    add_start_docstrings_to_model_forward,
    cached_property,
    copy_func,
    default_cache_path,
    define_sagemaker_information,
    get_cached_models,
    get_file_from_repo,
    get_full_repo_name,
    get_torch_version,
    has_file,
    http_user_agent,
    is_apex_available,
    is_bsa_available,
    is_coloredlogs_available,
    is_datasets_available,
    is_detectrona_available,
    is_faiss_available,
    is_flax_available,
    is_ftfy_available,
    is_in_notebook,
    is_ipex_available,
    is_librosa_available,
    is_offline_mode,
    is_onnx_available,
    is_pandas_available,
    is_phonemizer_available,
    is_protobuf_available,
    is_psutil_available,
    is_pyanvml_available,
    is_pyctcdecode_available,
    is_pytesseract_available,
    is_pytorch_quantization_available,
    is_rjieba_available,
    is_sagemaker_dp_enabled,
    is_sagemaker_mp_enabled,
    is_scipy_available,
    is_sentencepiece_available,
    is_seqio_available,
    is_sklearn_available,
    is_soundfile_availble,
    is_spacy_available,
    is_speech_available,
    is_tensor,
    is_tensorflow_probability_available,
    is_tfaonnx_available,
    is_tf_available,
    is_timm_available,
    is_tokenizers_available,
    is_torch_available,
    is_torch_bfaa_available,
    is_torch_cuda_available,
    is_torch_fx_available,
    is_torch_fx_proxy,
    is_torch_mps_available,
    is_torch_tfaa_available,
    is_torch_tpu_available,
    is_torchaudio_available,
    is_training_run_on_sagemaker,
    is_vision_available,
    replace_return_docstrings,
    requires_backends,
    to_numpy,
    to_py_obj,
    torch_only_method,
)
