


# this script reports modified .py files under the desired list of top-level sub-dirs passed as a list of arguments, e.g.:
#   python ./utils/get_modified_files.py utils src tests examples
#
# it uses git to find the forking point and which files were modified - i.e. files not under git won't be considered
# since the output of this script is fed into Makefile commands it doesn't print a newline after the results

import re
import subprocess
import sys


__UpperCAmelCase : Optional[Any] 			=				subprocess.check_output("git merge-base main HEAD".split()).decode("utf-8")
__UpperCAmelCase : Optional[Any] 			=				(
    subprocess.check_output(f'''git diff --diff-filter=d --name-only {fork_point_sha}'''.split()).decode("utf-8").split()
)

__UpperCAmelCase : str 			=				"|".join(sys.argv[1:])
__UpperCAmelCase : Tuple 			=				re.compile(rf'''^({joined_dirs}).*?\.py$''')

__UpperCAmelCase : Optional[Any] 			=				[x for x in modified_files if regex.match(x)]
print(" ".join(relevant_modified_files), end="")





import json
import os
import tempfile

import transformers

import datasets
from utils import generate_example_dataset, get_duration


__UpperCAmelCase : Optional[int] 			=				500000

__UpperCAmelCase			,    __UpperCAmelCase : Any 			=				os.path.split(__file__)
__UpperCAmelCase : int 			=				os.path.join(RESULTS_BASEPATH, "results", RESULTS_FILENAME.replace(".py", ".json"))


@get_duration
def      a	(							SCREAMING_SNAKE_CASE_      :		datasets.Dataset							,			**SCREAMING_SNAKE_CASE_      :		Union[str, Any]       ):






       """simple docstring"""





       UpperCamelCase    :	Tuple   	=		dataset.map(**SCREAMING_SNAKE_CASE_       )


@get_duration
def      a	(							SCREAMING_SNAKE_CASE_      :		datasets.Dataset							,			**SCREAMING_SNAKE_CASE_      :		Any       ):






       """simple docstring"""





       UpperCamelCase    :	int   	=		dataset.filter(**SCREAMING_SNAKE_CASE_       )


def      a	(							):






       """simple docstring"""





       UpperCamelCase    :	Optional[int]   	=		{'''num examples''': SPEED_TEST_N_EXAMPLES}
       with tempfile.TemporaryDirectory() as tmp_dir:
              UpperCamelCase    :	Dict   	=		datasets.Features({'''text''': datasets.Value('''string'''       ), '''numbers''': datasets.Value('''float32'''       )}       )
              UpperCamelCase    :	List[str]   	=		generate_example_dataset(
                  os.path.join(SCREAMING_SNAKE_CASE_							,			'''dataset.arrow'''       )							,			SCREAMING_SNAKE_CASE_							,			num_examples=SCREAMING_SNAKE_CASE_       )

              UpperCamelCase    :	Union[str, Any]   	=		transformers.AutoTokenizer.from_pretrained('''bert-base-cased'''							,			use_fast=SCREAMING_SNAKE_CASE_       )

              def tokenize(SCREAMING_SNAKE_CASE_      :		Dict       ):
                     return tokenizer(examples['''text''']       )

              UpperCamelCase    :	List[Any]   	=		map(SCREAMING_SNAKE_CASE_       )

              UpperCamelCase    :	List[str]   	=		map(SCREAMING_SNAKE_CASE_							,			batched=SCREAMING_SNAKE_CASE_       )

              UpperCamelCase    :	List[Any]   	=		map(SCREAMING_SNAKE_CASE_							,			function=lambda SCREAMING_SNAKE_CASE_       : None							,			batched=SCREAMING_SNAKE_CASE_       )

              with dataset.formatted_as(type='''numpy'''       ):
                     UpperCamelCase    :	Tuple   	=		map(SCREAMING_SNAKE_CASE_							,			function=lambda SCREAMING_SNAKE_CASE_       : None							,			batched=SCREAMING_SNAKE_CASE_       )

              with dataset.formatted_as(type='''pandas'''       ):
                     UpperCamelCase    :	int   	=		map(SCREAMING_SNAKE_CASE_							,			function=lambda SCREAMING_SNAKE_CASE_       : None							,			batched=SCREAMING_SNAKE_CASE_       )

              with dataset.formatted_as(type='''torch'''							,			columns='''numbers'''       ):
                     UpperCamelCase    :	Dict   	=		map(SCREAMING_SNAKE_CASE_							,			function=lambda SCREAMING_SNAKE_CASE_       : None							,			batched=SCREAMING_SNAKE_CASE_       )

              with dataset.formatted_as(type='''tensorflow'''							,			columns='''numbers'''       ):
                     UpperCamelCase    :	Tuple   	=		map(SCREAMING_SNAKE_CASE_							,			function=lambda SCREAMING_SNAKE_CASE_       : None							,			batched=SCREAMING_SNAKE_CASE_       )

              UpperCamelCase    :	List[str]   	=		map(SCREAMING_SNAKE_CASE_							,			function=SCREAMING_SNAKE_CASE_							,			batched=SCREAMING_SNAKE_CASE_       )

              UpperCamelCase    :	Dict   	=		filter(SCREAMING_SNAKE_CASE_       )

              # Activate later when tokenizer support batched inputs
              # with dataset.formatted_as(type='numpy'):
              #     times[func.__name__ + " fast-tokenizer batched numpy"] = func(dataset, function=tokenize, batched=True)

       with open(SCREAMING_SNAKE_CASE_							,			'''wb'''       ) as f:
              f.write(json.dumps(SCREAMING_SNAKE_CASE_       ).encode('''utf-8'''       )       )


if __name__ == "__main__":  # useful to run the profiler
  benchmark_map_filter()

