





import argparse

import torch

from transformers import ElectraConfig, ElectraForMaskedLM, ElectraForPreTraining, load_tf_weights_in_electra
from transformers.utils import logging


logging.set_verbosity_info()





def  __UpperCamelCase   (     a,  a,  a,  a)			->Union[str, Any]:
					lowerCamelCase__      =							ElectraConfig.from_json_file(__lowerCamelCase)
					print(f"Building PyTorch model from configuration: {config}")

					if discriminator_or_generator == "discriminator":
										lowerCamelCase__      =							ElectraForPreTraining(__lowerCamelCase)
					elif discriminator_or_generator == "generator":
										lowerCamelCase__      =							ElectraForMaskedLM(__lowerCamelCase)
					else:
										raise ValueError("The discriminator_or_generator argument should be either 'discriminator' or 'generator'")

					# Load weights from tf checkpoint
					load_tf_weights_in_electra(
					    __lowerCamelCase,  __lowerCamelCase,  __lowerCamelCase,  discriminator_or_generator=__lowerCamelCase)

					# Save pytorch-model
					print(f"Save PyTorch model to {pytorch_dump_path}")
					torch.save(model.state_dict(),  __lowerCamelCase)


if __name__ == "__main__":
						A_        =  argparse.ArgumentParser()
						# Required parameters
						parser.add_argument(
						    "--tf_checkpoint_path", default=None, type=str, required=True, help="Path to the TensorFlow checkpoint path."
						)
						parser.add_argument(
						    "--config_file",
						    default=None,
						    type=str,
						    required=True,
						    help="The config json file corresponding to the pre-trained model. \nThis specifies the model architecture.",
						)
						parser.add_argument(
						    "--pytorch_dump_path", default=None, type=str, required=True, help="Path to the output PyTorch model."
						)
						parser.add_argument(
						    "--discriminator_or_generator",
						    default=None,
						    type=str,
						    required=True,
						    help=(
						        "Whether to export the generator or the discriminator. Should be a string, either 'discriminator' or "
						        "'generator'."
						    ),
						)
						A_        =  parser.parse_args()
						convert_tf_checkpoint_to_pytorch(
						    args.tf_checkpoint_path, args.config_file, args.pytorch_dump_path, args.discriminator_or_generator
						)





import argparse
import logging
import sys
import time

import tensorflow as tf
from datasets import load_dataset

from transformers import AutoTokenizer, TFAutoModelForSequenceClassification


if __name__ == "__main__":
							SCREAMING_SNAKE_CASE__       			=				argparse.ArgumentParser()

							# Hyperparameters sent by the client are passed as command-line arguments to the script.
							parser.add_argument("""--epochs""", type=int, default=1)
							parser.add_argument("""--per_device_train_batch_size""", type=int, default=1_6)
							parser.add_argument("""--per_device_eval_batch_size""", type=int, default=8)
							parser.add_argument("""--model_name_or_path""", type=str)
							parser.add_argument("""--learning_rate""", type=str, default=5E-5)
							parser.add_argument("""--do_train""", type=bool, default=True)
							parser.add_argument("""--do_eval""", type=bool, default=True)
							parser.add_argument("""--output_dir""", type=str)

							SCREAMING_SNAKE_CASE__			,      SCREAMING_SNAKE_CASE__       			=				parser.parse_known_args()

							# overwrite batch size until we have tf_glue.py
							SCREAMING_SNAKE_CASE__       			=				1_6
							SCREAMING_SNAKE_CASE__       			=				1_6

							# Set up logging
							SCREAMING_SNAKE_CASE__       			=				logging.getLogger(__name__)

							logging.basicConfig(
							    level=logging.getLevelName("""INFO"""),
							    handlers=[logging.StreamHandler(sys.stdout)],
							    format="""%(asctime)s - %(name)s - %(levelname)s - %(message)s""",
							)

							# Load model and tokenizer
							SCREAMING_SNAKE_CASE__       			=				TFAutoModelForSequenceClassification.from_pretrained(args.model_name_or_path)
							SCREAMING_SNAKE_CASE__       			=				AutoTokenizer.from_pretrained(args.model_name_or_path)

							# Load dataset
							SCREAMING_SNAKE_CASE__			,      SCREAMING_SNAKE_CASE__       			=				load_dataset("""imdb""", split=["""train""", """test"""])
							SCREAMING_SNAKE_CASE__       			=				train_dataset.shuffle().select(range(5_0_0_0))  # smaller the size for train dataset to 5k
							SCREAMING_SNAKE_CASE__       			=				test_dataset.shuffle().select(range(5_0_0))  # smaller the size for test dataset to 500

							# Preprocess train dataset
							SCREAMING_SNAKE_CASE__       			=				train_dataset.map(
							    lambda e: tokenizer(e["""text"""], truncation=True, padding="""max_length"""), batched=True
							)
							train_dataset.set_format(type="""tensorflow""", columns=["""input_ids""", """attention_mask""", """label"""])

							SCREAMING_SNAKE_CASE__       			=				{
							    x: train_dataset[x].to_tensor(default_value=0, shape=[None, tokenizer.model_max_length])
							    for x in ["""input_ids""", """attention_mask"""]
							}
							SCREAMING_SNAKE_CASE__       			=				tf.data.Dataset.from_tensor_slices((train_features, train_dataset["""label"""])).batch(
							    args.per_device_train_batch_size
							)

							# Preprocess test dataset
							SCREAMING_SNAKE_CASE__       			=				test_dataset.map(
							    lambda e: tokenizer(e["""text"""], truncation=True, padding="""max_length"""), batched=True
							)
							test_dataset.set_format(type="""tensorflow""", columns=["""input_ids""", """attention_mask""", """label"""])

							SCREAMING_SNAKE_CASE__       			=				{
							    x: test_dataset[x].to_tensor(default_value=0, shape=[None, tokenizer.model_max_length])
							    for x in ["""input_ids""", """attention_mask"""]
							}
							SCREAMING_SNAKE_CASE__       			=				tf.data.Dataset.from_tensor_slices((test_features, test_dataset["""label"""])).batch(
							    args.per_device_eval_batch_size
							)

							# fine optimizer and loss
							SCREAMING_SNAKE_CASE__       			=				tf.keras.optimizers.Adam(learning_rate=args.learning_rate)
							SCREAMING_SNAKE_CASE__       			=				tf.keras.losses.SparseCategoricalCrossentropy(from_logits=True)
							SCREAMING_SNAKE_CASE__       			=				[tf.keras.metrics.SparseCategoricalAccuracy()]
							model.compile(optimizer=optimizer, loss=loss, metrics=metrics)

							SCREAMING_SNAKE_CASE__       			=				time.time()
							SCREAMING_SNAKE_CASE__       			=				model.fit(tf_train_dataset, epochs=args.epochs, batch_size=args.per_device_train_batch_size)
							SCREAMING_SNAKE_CASE__       			=				time.time() - start_train_time

							logger.info("""*** Train ***""")
							logger.info(f"""train_runtime = {end_train_time}""")
							for key, value in train_results.history.items():
														logger.info(f"""  {key} = {value}""")

