import unittest

from transformers import load_tool

from .test_tools_common import ToolTesterMixin


__lowerCamelCase     :					List[str]				  =						'\nHugging Face was founded in 2016 by French entrepreneurs Clément Delangue, Julien Chaumond, and Thomas Wolf originally as a company that developed a chatbot app targeted at teenagers.[2] After open-sourcing the model behind the chatbot, the company pivoted to focus on being a platform for machine learning.\n\nIn March 2021, Hugging Face raised $40 million in a Series B funding round.[3]\n\nOn April 28, 2021, the company launched the BigScience Research Workshop in collaboration with several other research groups to release an open large language model.[4] In 2022, the workshop concluded with the announcement of BLOOM, a multilingual large language model with 176 billion parameters.[5]\n'







class __snake_case							(		unittest.TestCase  ,						A__						):




   def       __a		(       self     :							Tuple ):



     """simple docstring"""






     SCREAMING_SNAKE_CASE__     				= load_tool("""summarization""" )
     self.tool.setup()
     SCREAMING_SNAKE_CASE__     				= load_tool("""summarization"""			,      remote=_lowerCAmelCase )




   def       __a		(       self     :							Any ):



     """simple docstring"""






     SCREAMING_SNAKE_CASE__     				= self.tool(_lowerCAmelCase )
     self.assertEqual(
         _lowerCAmelCase			,      """Hugging Face was founded in 2016 by French entrepreneurs Clément Delangue, Julien Chaumond, and Thomas Wolf. In March 2021, Hugging Face raised $40 million in a Series B funding round. On April 28, 2021, the company launched the BigScience Research Workshop in collaboration with several other research groups to release an open large language model. In 2022, the workshop concluded with the announcement of BLOOM."""			,      )




   def       __a		(       self     :							Union[str, Any] ):



     """simple docstring"""






     SCREAMING_SNAKE_CASE__     				= self.remote_tool(_lowerCAmelCase )
     self.assertEqual(
         _lowerCAmelCase			,      """Hugging Face was founded in 2016 by French entrepreneurs Clément Delangue, Julien Chaumond, and Thomas Wolf. In March 2021, Hugging Face raised $40 million in a Series B funding round. On April 28, 2021, the company launched the BigScience Research Workshop in collaboration with several other research groups to release an open large language model. In 2022, the workshop concluded with the announcement of BLOOM."""			,      )




   def       __a		(       self     :							Optional[int] ):



     """simple docstring"""






     SCREAMING_SNAKE_CASE__     				= self.tool(text=_lowerCAmelCase )
     self.assertEqual(
         _lowerCAmelCase			,      """Hugging Face was founded in 2016 by French entrepreneurs Clément Delangue, Julien Chaumond, and Thomas Wolf. In March 2021, Hugging Face raised $40 million in a Series B funding round. On April 28, 2021, the company launched the BigScience Research Workshop in collaboration with several other research groups to release an open large language model. In 2022, the workshop concluded with the announcement of BLOOM."""			,      )




   def       __a		(       self     :							List[str] ):



     """simple docstring"""






     SCREAMING_SNAKE_CASE__     				= self.remote_tool(text=_lowerCAmelCase )
     self.assertEqual(
         _lowerCAmelCase			,      """Hugging Face was founded in 2016 by French entrepreneurs Clément Delangue, Julien Chaumond, and Thomas Wolf. In March 2021, Hugging Face raised $40 million in a Series B funding round. On April 28, 2021, the company launched the BigScience Research Workshop in collaboration with several other research groups to release an open large language model. In 2022, the workshop concluded with the announcement of BLOOM."""			,      )







'''simple docstring'''


import logging
import random

import ray

from transformers import RagConfig, RagRetriever, RagTokenizer
from transformers.models.rag.retrieval_rag import CustomHFIndex


_lowerCamelCase					:						List[str]					     =							logging.getLogger(__name__)



class 				__UpperCAmelCase	:







		'''simple docstring'''







		def __init__(self    :   Any   ):
			A					=   False







		def 							A  (self    :   Tuple   ,   _lowerCAmelCase    :   Dict   ,   _lowerCAmelCase    :   Any   ,   _lowerCAmelCase    :   Tuple   ,   _lowerCAmelCase    :   Dict   ):
			if not self.initialized:
				A					=   RagRetriever(
				    _lowerCAmelCase   ,   question_encoder_tokenizer=_lowerCAmelCase   ,   generator_tokenizer=_lowerCAmelCase   ,   index=_lowerCAmelCase   ,   init_retrieval=_lowerCAmelCase   ,   )
				A					=   True







		def 							A  (self    :   List[str]   ):
			self.retriever.index.init_index()







		def 							A  (self    :   List[str]   ):
			# delete the old self.retriever object before assigning the new index
			del self.retriever
			A					=   False







		def 							A  (self    :   Any   ,   _lowerCAmelCase    :   List[str]   ,   _lowerCAmelCase    :   Optional[int]   ):
			A	,     A					=   self.retriever._main_retrieve(_lowerCAmelCase   ,   _lowerCAmelCase   )
			A					=   self.retriever.index.get_doc_dicts(_lowerCAmelCase   )
			return doc_ids, retrieved_doc_embeds, doc_dicts






class 				__UpperCAmelCase	(							A__    ):







		'''simple docstring'''







		def __init__(self    :   Any   ,   _lowerCAmelCase    :   Dict   ,   _lowerCAmelCase    :   Dict   ,   _lowerCAmelCase    :   Union[str, Any]   ,   _lowerCAmelCase    :   Dict   ,   _lowerCAmelCase    :   List[Any]=None   ):
			if index is not None and index.is_initialized() and len(_lowerCAmelCase   ) > 0:
				raise ValueError(
				    """When using Ray for distributed fine-tuning, """
				    """you'll need to provide the paths instead, """
				    """as the dataset and the index are loaded """
				    """separately. More info in examples/rag/use_own_knowledge_dataset.py """   )

			super().__init__(
			    _lowerCAmelCase   ,   question_encoder_tokenizer=_lowerCAmelCase   ,   generator_tokenizer=_lowerCAmelCase   ,   index=_lowerCAmelCase   ,   init_retrieval=_lowerCAmelCase   ,   )

			A					=   retrieval_workers
			A					=   question_encoder_tokenizer
			A					=   generator_tokenizer
			if len(self.retrieval_workers   ) > 0:
				ray.get(
				    [
				        worker.create_rag_retriever.remote(_lowerCAmelCase   ,   _lowerCAmelCase   ,   _lowerCAmelCase   ,   _lowerCAmelCase   )
				        for worker in self.retrieval_workers
				    ]   )







		def 							A  (self    :   Optional[Any]   ):
			logger.info("""initializing retrieval"""   )

			if len(self.retrieval_workers   ) > 0:
				ray.get([worker.init_retrieval.remote() for worker in self.retrieval_workers]   )
			else:
				# Non-distributed training. Load index into this same process.
				self.index.init_index()







		def 							A  (self    :   int   ,   _lowerCAmelCase    :   Dict   ,   _lowerCAmelCase    :   List[Any]   ):
			if len(self.retrieval_workers   ) > 0:
				# Select a random retrieval actor.
				A					=   self.retrieval_workers[random.randint(0   ,   len(self.retrieval_workers   ) - 1   )]
				A	,     A	,     A					=   ray.get(
				    random_worker.retrieve.remote(_lowerCAmelCase   ,   _lowerCAmelCase   )   )
			else:
				A	,     A					=   self._main_retrieve(_lowerCAmelCase   ,   _lowerCAmelCase   )
				A					=   self.index.get_doc_dicts(_lowerCAmelCase   )
			return retrieved_doc_embeds, doc_ids, doc_dicts







		@classmethod
		def 							A  (cls    :   Dict   ,   _lowerCAmelCase    :   Tuple   ,   _lowerCAmelCase    :   str=None   ,   **_lowerCAmelCase    :   List[Any]   ):
			return super(_lowerCAmelCase   ,   cls   ).get_tokenizers(_lowerCAmelCase   ,   _lowerCAmelCase   ,   **_lowerCAmelCase   )







		@classmethod
		def 							A  (cls    :   List[str]   ,   _lowerCAmelCase    :   List[str]   ,   _lowerCAmelCase    :   List[Any]   ,   _lowerCAmelCase    :   Optional[int]=None   ,   **_lowerCAmelCase    :   Optional[int]   ):
			A					=   kwargs.pop("""config"""   ,   _lowerCAmelCase   ) or RagConfig.from_pretrained(_lowerCAmelCase   ,   **_lowerCAmelCase   )
			A					=   RagTokenizer.from_pretrained(_lowerCAmelCase   ,   config=_lowerCAmelCase   )
			A					=   rag_tokenizer.question_encoder
			A					=   rag_tokenizer.generator

			if indexed_dataset is not None:
				A					=   """custom"""
				A					=   CustomHFIndex(config.retrieval_vector_size   ,   _lowerCAmelCase   )
			else:
				A					=   cls._build_index(_lowerCAmelCase   )

			return cls(
			    _lowerCAmelCase   ,   question_encoder_tokenizer=_lowerCAmelCase   ,   generator_tokenizer=_lowerCAmelCase   ,   retrieval_workers=_lowerCAmelCase   ,   index=_lowerCAmelCase   ,   )







		def 							A  (self    :   str   ):
			logger.info("""re-loading the new dataset with embeddings"""   )
			# access from the training loop

			ray.get([worker.clear_object.remote() for worker in self.retrieval_workers]   )

			# build the index object again
			A					=   self._build_index(self.config   )

			ray.get(
			    [
			        worker.create_rag_retriever.remote(
			            self.config   ,   self.question_encoder_tokenizer   ,   self.generator_tokenizer   ,   _lowerCAmelCase   )
			        for worker in self.retrieval_workers
			    ]   )

