



'''simple docstring'''


import math
import random
from typing import Any

from .hill_climbing import SearchProblem







def 				__lowerCamelCase				(   A__    ,						A__ = True    ,						A__ = math.inf    ,						A__ = -math.inf    ,						A__ = math.inf    ,						A__ = -math.inf    ,						A__ = False    ,						A__ = 100    ,						A__ = 0.01    ,						A__ = 1    ,						)       ->	Any:






   """simple docstring"""
   UpperCamelCase					=  False
   UpperCamelCase					=  search_prob
   UpperCamelCase					=  start_temperate
   UpperCamelCase					=  []
   UpperCamelCase					=  0
   UpperCamelCase					=  None

   while not search_end:
      UpperCamelCase					=  current_state.score()
      if best_state is None or current_score > best_state.score():
         UpperCamelCase					=  current_state
      scores.append(A__    )
      iterations += 1
      UpperCamelCase					=  None
      UpperCamelCase					=  current_state.get_neighbors()
      while (
          next_state is None and neighbors
      ):  # till we do not find a neighbor that we can move to
         UpperCamelCase					=  random.randint(0    ,						len(A__    ) - 1    )  # picking a random neighbor
         UpperCamelCase					=  neighbors.pop(A__    )
         UpperCamelCase					=  picked_neighbor.score() - current_score

         if (
             picked_neighbor.x > max_x
             or picked_neighbor.x < min_x
             or picked_neighbor.y > max_y
             or picked_neighbor.y < min_y
         ):
            continue  # neighbor outside our bounds

         if not find_max:
            UpperCamelCase					=  change * -1  # in case we are finding minimum
         if change > 0:  # improves the solution
            UpperCamelCase					=  picked_neighbor
         else:
            UpperCamelCase					=  (math.e) ** (
                change / current_temp
            )  # probability generation function
            if random.random() < probability:  # random number within probability
               UpperCamelCase					=  picked_neighbor
      UpperCamelCase					=  current_temp - (current_temp * rate_of_decrease)

      if current_temp < threshold_temp or next_state is None:
         # temperature below threshold, or could not find a suitable neighbor
         UpperCamelCase					=  True
      else:
         UpperCamelCase					=  next_state

   if visualization:
      from matplotlib import pyplot as plt

      plt.plot(range(A__    )    ,						A__    )
      plt.xlabel('Iterations'    )
      plt.ylabel('Function values'    )
      plt.show()
   return best_state


if __name__ == "__main__":







   def 				__lowerCamelCase				(   A__    ,						A__    )       ->	Union[str, Any]:






      """simple docstring"""
      return (x**2) + (y**2)

   # starting the problem with initial coordinates (12, 47)
   _lowerCamelCase	:       Tuple      	=	SearchProblem(x=12, y=47, step_size=1, function_to_optimize=test_fa)
   _lowerCamelCase	:       Optional[Any]      	=	simulated_annealing(
       prob, find_max=False, max_x=100, min_x=5, max_y=50, min_y=-5, visualization=True
   )
   print(
       "The minimum score for f(x, y) = x^2 + y^2 with the domain 100 > x > 5 "
       f'''and 50 > y > - 5 found via hill climbing: {local_min.score()}'''
   )

   # starting the problem with initial coordinates (12, 47)
   _lowerCamelCase	:       Optional[Any]      	=	SearchProblem(x=12, y=47, step_size=1, function_to_optimize=test_fa)
   _lowerCamelCase	:       List[Any]      	=	simulated_annealing(
       prob, find_max=True, max_x=100, min_x=5, max_y=50, min_y=-5, visualization=True
   )
   print(
       "The maximum score for f(x, y) = x^2 + y^2 with the domain 100 > x > 5 "
       f'''and 50 > y > - 5 found via hill climbing: {local_min.score()}'''
   )







   def 				__lowerCamelCase				(   A__    ,						A__    )       ->	int:






      """simple docstring"""
      return (3 * x**2) - (6 * y)

   _lowerCamelCase	:       Optional[int]      	=	SearchProblem(x=3, y=4, step_size=1, function_to_optimize=test_fa)
   _lowerCamelCase	:       Tuple      	=	simulated_annealing(prob, find_max=False, visualization=True)
   print(
       "The minimum score for f(x, y) = 3*x^2 - 6*y found via hill climbing: "
       f'''{local_min.score()}'''
   )

   _lowerCamelCase	:       List[Any]      	=	SearchProblem(x=3, y=4, step_size=1, function_to_optimize=test_fa)
   _lowerCamelCase	:       str      	=	simulated_annealing(prob, find_max=True, visualization=True)
   print(
       "The maximum score for f(x, y) = 3*x^2 - 6*y found via hill climbing: "
       f'''{local_min.score()}'''
   )






'''simple docstring'''


import inspect
import logging
import os
import random
import shutil
import tempfile
import unittest

import pytest
import torch
from torch import nn
from torch.utils.data import DataLoader, TensorDataset

from accelerate import Accelerator
from accelerate.test_utils import execute_subprocess_async, require_cuda
from accelerate.utils import ProjectConfiguration, set_seed


_lowerCamelCase	:       Optional[int]      	=	logging.getLogger(__name__)







def 				__lowerCamelCase				(   A__=2    ,						A__=3    ,						A__=16    ,						A__ = 10    ,						A__ = 2    )       ->	int:






   """simple docstring"""

   def get_dataset(A__    ):
      UpperCamelCase					=  torch.randn(batch_size * n_batches    ,						1    )
      return TensorDataset(A__    ,						a * x + b + 0.1 * torch.randn(batch_size * n_batches    ,						1    )    )

   UpperCamelCase					=  get_dataset(A__    )
   UpperCamelCase					=  get_dataset(A__    )
   UpperCamelCase					=  DataLoader(A__    ,						shuffle=A__    ,						batch_size=A__    ,						num_workers=4    )
   UpperCamelCase					=  DataLoader(A__    ,						shuffle=A__    ,						batch_size=A__    ,						num_workers=4    )
   return (train_dataloader, valid_dataloader)







def 				__lowerCamelCase				(   A__    ,						A__    ,						A__    ,						A__    ,						A__    ,						A__=None    )       ->	int:






   """simple docstring"""
   UpperCamelCase					=  []
   for epoch in range(A__    ):
      # Train quickly
      model.train()
      for batch in dataloader:
         UpperCamelCase				,      UpperCamelCase					=  batch
         UpperCamelCase					=  model(A__    )
         UpperCamelCase					=  torch.nn.functional.mse_loss(A__    ,						A__    )
         accelerator.backward(A__    )
         optimizer.step()
         optimizer.zero_grad()
      rands.append(random.random()    )  # Introduce some randomness
      if scheduler is not None:
         scheduler.step()
   return rands

class  SCREAMING_SNAKE_CASE (  nn.Module		):






    """simple docstring"""





    def __init__(  self      :					Tuple ):


       """simple docstring"""







       super().__init__()
       UpperCamelCase					=  nn.Parameter(torch.randn(1 ) )
       UpperCamelCase					=  nn.Parameter(torch.randn(1 ) )






    def  A       (  self      :					str  ,						UpperCamelCase__      :					Dict ):


       """simple docstring"""







       return x * self.a + self.b

class  SCREAMING_SNAKE_CASE (  unittest.TestCase		):






    """simple docstring"""





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


       """simple docstring"""







       with tempfile.TemporaryDirectory() as tmpdir:
          set_seed(4_2 )
          UpperCamelCase					=  DummyModel()
          UpperCamelCase					=  torch.optim.Adam(params=model.parameters()  ,						lr=1E-3 )
          UpperCamelCase				,      UpperCamelCase					=  dummy_dataloaders()
          UpperCamelCase					=  ProjectConfiguration(total_limit=1  ,						project_dir=UpperCamelCase__  ,						automatic_checkpoint_naming=UpperCamelCase__ )
          # Train baseline
          UpperCamelCase					=  Accelerator(project_config=UpperCamelCase__ )
          UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase					=  accelerator.prepare(
              UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          # Save initial
          accelerator.save_state()

          # Save second state
          accelerator.save_state()
          self.assertEqual(len(os.listdir(accelerator.project_dir ) )  ,						1 )






    def  A       (  self      :					Optional[int] ):


       """simple docstring"""







       with tempfile.TemporaryDirectory() as tmpdir:
          set_seed(4_2 )
          UpperCamelCase					=  DummyModel()
          UpperCamelCase					=  torch.optim.Adam(params=model.parameters()  ,						lr=1E-3 )
          UpperCamelCase				,      UpperCamelCase					=  dummy_dataloaders()
          # Train baseline
          UpperCamelCase					=  Accelerator()
          UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase					=  accelerator.prepare(
              UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          # Save initial
          UpperCamelCase					=  os.path.join(UpperCamelCase__  ,						'initial' )
          accelerator.save_state(UpperCamelCase__ )
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()
          UpperCamelCase					=  train(3  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()

          # Train partially
          set_seed(4_2 )
          UpperCamelCase					=  DummyModel()
          UpperCamelCase					=  torch.optim.Adam(params=model.parameters()  ,						lr=1E-3 )
          UpperCamelCase				,      UpperCamelCase					=  dummy_dataloaders()
          UpperCamelCase					=  Accelerator()
          UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase					=  accelerator.prepare(
              UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          accelerator.load_state(UpperCamelCase__ )
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )

          UpperCamelCase					=  train(2  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          # Save everything
          UpperCamelCase					=  os.path.join(UpperCamelCase__  ,						'checkpoint' )
          accelerator.save_state(UpperCamelCase__ )

          # Load everything back in and make sure all states work
          accelerator.load_state(UpperCamelCase__ )
          test_rands += train(1  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )






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


       """simple docstring"""







       with tempfile.TemporaryDirectory() as tmpdir:
          set_seed(4_2 )
          UpperCamelCase					=  DummyModel()
          UpperCamelCase					=  torch.optim.Adam(params=model.parameters()  ,						lr=1E-3 )
          UpperCamelCase				,      UpperCamelCase					=  dummy_dataloaders()
          UpperCamelCase					=  ProjectConfiguration(automatic_checkpoint_naming=UpperCamelCase__ )

          # Train baseline
          UpperCamelCase					=  Accelerator(project_dir=UpperCamelCase__  ,						project_config=UpperCamelCase__ )
          UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase					=  accelerator.prepare(
              UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          # Save initial
          accelerator.save_state()
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()
          UpperCamelCase					=  train(3  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()

          # Train partially
          set_seed(4_2 )
          UpperCamelCase					=  DummyModel()
          UpperCamelCase					=  torch.optim.Adam(params=model.parameters()  ,						lr=1E-3 )
          UpperCamelCase				,      UpperCamelCase					=  dummy_dataloaders()
          UpperCamelCase					=  ProjectConfiguration(iteration=1  ,						automatic_checkpoint_naming=UpperCamelCase__ )
          UpperCamelCase					=  Accelerator(project_dir=UpperCamelCase__  ,						project_config=UpperCamelCase__ )
          UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase					=  accelerator.prepare(
              UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          accelerator.load_state(os.path.join(UpperCamelCase__  ,						'checkpoints'  ,						'checkpoint_0' ) )
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )

          UpperCamelCase					=  train(2  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          # Save everything
          accelerator.save_state()

          # Load everything back in and make sure all states work
          accelerator.load_state(os.path.join(UpperCamelCase__  ,						'checkpoints'  ,						'checkpoint_1' ) )
          test_rands += train(1  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          ((UpperCamelCase)				,      (UpperCamelCase))					=  model.a.item(), model.b.item()
          UpperCamelCase					=  optimizer.state_dict()
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertEqual(UpperCamelCase__  ,						UpperCamelCase__ )






    def  A       (  self      :					Optional[int] ):


       """simple docstring"""







       UpperCamelCase					=  torch.tensor([1, 2, 3] )
       UpperCamelCase					=  torch.tensor([2, 3, 4] )
       UpperCamelCase					=  DummyModel()
       UpperCamelCase					=  torch.optim.Adam(net.parameters() )
       UpperCamelCase					=  Accelerator()
       with self.assertRaises(UpperCamelCase__ ) as ve:
          accelerator.register_for_checkpointing(UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
       UpperCamelCase					=  str(ve.exception )
       self.assertTrue('Item at index 0' in message )
       self.assertTrue('Item at index 1' in message )
       self.assertFalse('Item at index 2' in message )
       self.assertFalse('Item at index 3' in message )






    def  A       (  self      :					Dict ):


       """simple docstring"""







       with tempfile.TemporaryDirectory() as tmpdir:
          set_seed(4_2 )
          UpperCamelCase					=  DummyModel()
          UpperCamelCase					=  torch.optim.Adam(params=model.parameters()  ,						lr=1E-3 )
          UpperCamelCase					=  torch.optim.lr_scheduler.StepLR(UpperCamelCase__  ,						step_size=1  ,						gamma=0.9_9 )
          UpperCamelCase				,      UpperCamelCase					=  dummy_dataloaders()
          UpperCamelCase					=  ProjectConfiguration(automatic_checkpoint_naming=UpperCamelCase__ )
          # Train baseline
          UpperCamelCase					=  Accelerator(project_dir=UpperCamelCase__  ,						project_config=UpperCamelCase__ )
          UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase				,      UpperCamelCase					=  accelerator.prepare(
              UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          # Save initial
          accelerator.save_state()
          UpperCamelCase					=  scheduler.state_dict()
          train(3  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__  ,						UpperCamelCase__ )
          self.assertNotEqual(UpperCamelCase__  ,						scheduler.state_dict() )

          # Load everything back in and make sure all states work
          accelerator.load_state(os.path.join(UpperCamelCase__  ,						'checkpoints'  ,						'checkpoint_0' ) )
          self.assertEqual(UpperCamelCase__  ,						scheduler.state_dict() )






    def  A       (  self      :					List[str] ):


       """simple docstring"""







       with tempfile.TemporaryDirectory() as tmpdir:
          set_seed(4_2 )
          UpperCamelCase					=  DummyModel()
          UpperCamelCase					=  ProjectConfiguration(automatic_checkpoint_naming=UpperCamelCase__  ,						total_limit=2 )
          # Train baseline
          UpperCamelCase					=  Accelerator(project_dir=UpperCamelCase__  ,						project_config=UpperCamelCase__ )
          UpperCamelCase					=  accelerator.prepare(UpperCamelCase__ )
          # Save 3 states:
          for _ in range(1_1 ):
             accelerator.save_state()
          self.assertTrue(not os.path.exists(os.path.join(UpperCamelCase__  ,						'checkpoints'  ,						'checkpoint_0' ) ) )
          self.assertTrue(os.path.exists(os.path.join(UpperCamelCase__  ,						'checkpoints'  ,						'checkpoint_9' ) ) )
          self.assertTrue(os.path.exists(os.path.join(UpperCamelCase__  ,						'checkpoints'  ,						'checkpoint_10' ) ) )






    @require_cuda
    def  A       (  self      :					Dict ):


       """simple docstring"""







       UpperCamelCase					=  ['torchrun', f"""--nproc_per_node={torch.cuda.device_count()}""", inspect.getfile(self.__class__ )]
       execute_subprocess_async(UpperCamelCase__  ,						env=os.environ.copy() )


if __name__ == "__main__":
   _lowerCamelCase	:       Optional[int]      	=	"/tmp/accelerate/state_checkpointing"
   _lowerCamelCase	:       Union[str, Any]      	=	DummyModel()
   _lowerCamelCase	:       Optional[Any]      	=	torch.optim.Adam(params=model.parameters(), lr=1e-3)
   _lowerCamelCase	:       List[Any]      	=	torch.optim.lr_scheduler.StepLR(optimizer, step_size=1, gamma=0.99)
   _lowerCamelCase	,_lowerCamelCase	:       Tuple      	=	dummy_dataloaders()
   _lowerCamelCase	:       List[Any]      	=	ProjectConfiguration(automatic_checkpoint_naming=True)
   # Train baseline
   _lowerCamelCase	:       Any      	=	Accelerator(project_dir=savedir, project_config=project_config, mixed_precision="no")
   if accelerator.process_index == 0:
      if os.path.exists(savedir):
         shutil.rmtree(savedir)
      os.makedirs(savedir)
   _lowerCamelCase	,_lowerCamelCase	,_lowerCamelCase	,_lowerCamelCase	,_lowerCamelCase	:       Union[str, Any]      	=	accelerator.prepare(
       model, optimizer, train_dataloader, valid_dataloader, scheduler
   )
   _lowerCamelCase	,_lowerCamelCase	:       Tuple      	=	accelerator.prepare(model, optimizer)
   train(3, model, train_dataloader, optimizer, accelerator, scheduler)
   # Check that the intial optimizer is loaded on the GPU
   for group in optimizer.param_groups:
      _lowerCamelCase	:       Any      	=	group["params"][0].device
      break
   assert param_device.type == accelerator.device.type
   _lowerCamelCase	:       Tuple      	=	model.cpu()
   accelerator.wait_for_everyone()
   accelerator.save_state()
   accelerator.wait_for_everyone()

   # Check CPU state
   accelerator.load_state(os.path.join(savedir, "checkpoints", "checkpoint_0"), map_location="cpu")
   for group in optimizer.param_groups:
      _lowerCamelCase	:       Optional[Any]      	=	group["params"][0].device
      break
   assert (
       param_device.type == torch.device("cpu").type
   ), f"Loaded optimizer states did not match, expected to be loaded on the CPU but got {param_device}"

   # Check device state
   model.to(accelerator.device)
   accelerator.load_state(os.path.join(savedir, "checkpoints", "checkpoint_0"), map_location="on_device")
   for group in optimizer.param_groups:
      _lowerCamelCase	:       Dict      	=	group["params"][0].device
      break
   assert (
       param_device.type == accelerator.device.type
   ), f"Loaded optimizer states did not match, expected to be loaded on {accelerator.device} but got {param_device}"

   # Check error
   with pytest.raises(TypeError, match="Unsupported optimizer map location passed"):
      accelerator.load_state(os.path.join(savedir, "checkpoints", "checkpoint_0"), map_location="invalid")
   accelerator.wait_for_everyone()
   if accelerator.process_index == 0:
      shutil.rmtree(savedir)
   accelerator.wait_for_everyone()

