



"""simple docstring"""





import json
import logging
import os
import sys
from time import time
from unittest.mock import patch

from transformers.testing_utils import TestCasePlus, require_torch_tpu


logging.basicConfig(level=logging.DEBUG)

lowerCamelCase  			=		logging.getLogger()
def   a__      ( lowerCAmelCase__ ):
      UpperCAmelCase_     					=				{}
      UpperCAmelCase_     					=				os.path.join(lowerCAmelCase_      ,     "all_results.json" )
      if os.path.exists(lowerCAmelCase_ ):
            with open(lowerCAmelCase_      ,     "r" ) as f:
                  UpperCAmelCase_     					=				json.load(lowerCAmelCase_ )
      else:
            raise ValueError(f"""can't find {path}""" )
      return results


lowerCamelCase  			=		logging.StreamHandler(sys.stdout)
logger.addHandler(stream_handler)


@require_torch_tpu
class  lowercase__  (       __snake_case ):







       '''simple docstring'''


       def 	lowercase__							(				self     :    Any       )					->		Dict:


             '''simple docstring'''




             import xla_spawn

             UpperCAmelCase_     					=				self.get_auto_remove_tmp_dir()
             UpperCAmelCase_     					=				F"""
            ./examples/pytorch/text-classification/run_glue.py
            --num_cores=8
            ./examples/pytorch/text-classification/run_glue.py
            --model_name_or_path distilbert-base-uncased
            --output_dir {tmp_dir}
            --overwrite_output_dir
            --train_file ./tests/fixtures/tests_samples/MRPC/train.csv
            --validation_file ./tests/fixtures/tests_samples/MRPC/dev.csv
            --do_train
            --do_eval
            --debug tpu_metrics_debug
            --per_device_train_batch_size=2
            --per_device_eval_batch_size=1
            --learning_rate=1e-4
            --max_steps=10
            --warmup_steps=2
            --seed=42
            --max_seq_length=128
            """.split()

             with patch.object(__lowerCamelCase						,							"argv"						,							__lowerCamelCase       ):
                   UpperCAmelCase_     					=				time()
                   xla_spawn.main()
                   UpperCAmelCase_     					=				time()

                   UpperCAmelCase_     					=				get_results(__lowerCamelCase       )
                   self.assertGreaterEqual(result["eval_accuracy"]						,							0.75       )

                   # Assert that the script takes less than 500 seconds to make sure it doesn't hang.
                   self.assertLess(end - start						,							500       )







       def 	lowercase__							(				self     :    Any       )					->		Optional[Any]:


             '''simple docstring'''




             import xla_spawn

             UpperCAmelCase_     					=				"\n            ./tests/test_trainer_tpu.py\n            --num_cores=8\n            ./tests/test_trainer_tpu.py\n            ".split()
             with patch.object(__lowerCamelCase						,							"argv"						,							__lowerCamelCase       ):
                   xla_spawn.main()








import argparse
import os

import numpy as np
import tensorflow as tf
import torch

from transformers import BertModel
def 	_UpperCamelCase					(    lowerCAmelCase_	,    lowerCAmelCase_	,    lowerCAmelCase_ )    ->Optional[Any]:
   UpperCAmelCase      					=  ("""dense.weight""", """attention.self.query""", """attention.self.key""", """attention.self.value""")

   UpperCAmelCase      					=  (
       ("""layer.""", """layer_"""),
       ("""word_embeddings.weight""", """word_embeddings"""),
       ("""position_embeddings.weight""", """position_embeddings"""),
       ("""token_type_embeddings.weight""", """token_type_embeddings"""),
       (""".""", """/"""),
       ("""LayerNorm/weight""", """LayerNorm/gamma"""),
       ("""LayerNorm/bias""", """LayerNorm/beta"""),
       ("""weight""", """kernel"""),
   )

   if not os.path.isdir(lowerCAmelCase_ ):
      os.makedirs(lowerCAmelCase_ )

   UpperCAmelCase      					=  model.state_dict()

   def to_tf_var_name(lowerCAmelCase_ ):
      for patt, repl in iter(lowerCAmelCase_ ):
         UpperCAmelCase      					=  name.replace(lowerCAmelCase_	,    lowerCAmelCase_ )
      return F"""bert/{name}"""

   def create_tf_var(lowerCAmelCase_	,    lowerCAmelCase_	,    lowerCAmelCase_ ):
      UpperCAmelCase      					=  tf.dtypes.as_dtype(tensor.dtype )
      UpperCAmelCase      					=  tf.get_variable(dtype=lowerCAmelCase_	,    shape=tensor.shape	,    name=lowerCAmelCase_	,    initializer=tf.zeros_initializer() )
      session.run(tf.variables_initializer([tf_var] ) )
      session.run(lowerCAmelCase_ )
      return tf_var

   tf.reset_default_graph()
   with tf.Session() as session:
      for var_name in state_dict:
         UpperCAmelCase      					=  to_tf_var_name(lowerCAmelCase_ )
         UpperCAmelCase      					=  state_dict[var_name].numpy()
         if any(x in var_name for x in tensors_to_transpose ):
            UpperCAmelCase      					=  torch_tensor.T
         UpperCAmelCase      					=  create_tf_var(tensor=lowerCAmelCase_	,    name=lowerCAmelCase_	,    session=lowerCAmelCase_ )
         tf.keras.backend.set_value(lowerCAmelCase_	,    lowerCAmelCase_ )
         UpperCAmelCase      					=  session.run(lowerCAmelCase_ )
         print(F"""Successfully created {tf_name}: {np.allclose(lowerCAmelCase_	,    lowerCAmelCase_ )}""" )

      UpperCAmelCase      					=  tf.train.Saver(tf.trainable_variables() )
      saver.save(lowerCAmelCase_	,    os.path.join(lowerCAmelCase_	,    model_name.replace("""-"""	,    """_""" ) + """.ckpt""" ) )
def 	_UpperCamelCase					(    lowerCAmelCase_=None )    ->Union[str, Any]:
   UpperCAmelCase      					=  argparse.ArgumentParser()
   parser.add_argument("""--model_name"""	,    type=lowerCAmelCase_	,    required=lowerCAmelCase_	,    help="""model name e.g. bert-base-uncased""" )
   parser.add_argument(
       """--cache_dir"""	,    type=lowerCAmelCase_	,    default=lowerCAmelCase_	,    required=lowerCAmelCase_	,    help="""Directory containing pytorch model""" )
   parser.add_argument("""--pytorch_model_path"""	,    type=lowerCAmelCase_	,    required=lowerCAmelCase_	,    help="""/path/to/<pytorch-model-name>.bin""" )
   parser.add_argument("""--tf_cache_dir"""	,    type=lowerCAmelCase_	,    required=lowerCAmelCase_	,    help="""Directory in which to save tensorflow model""" )
   UpperCAmelCase      					=  parser.parse_args(lowerCAmelCase_ )

   UpperCAmelCase      					=  BertModel.from_pretrained(
       pretrained_model_name_or_path=args.model_name	,    state_dict=torch.load(args.pytorch_model_path )	,    cache_dir=args.cache_dir	,    )

   convert_pytorch_checkpoint_to_tf(model=lowerCAmelCase_	,    ckpt_dir=args.tf_cache_dir	,    model_name=args.model_name )


if __name__ == "__main__":
 main()



