diff --git a/ignite/contrib/handlers/param_scheduler.py b/ignite/contrib/handlers/param_scheduler.py
index 9f780382..bd85a035 100644
--- a/ignite/contrib/handlers/param_scheduler.py
+++ b/ignite/contrib/handlers/param_scheduler.py
@@ -1,6 +1,7 @@
 from __future__ import division
 
-from copy import deepcopy
+from collections import OrderedDict
+from copy import copy
 
 import math
 import numbers
@@ -9,12 +10,13 @@ from abc import ABCMeta, abstractmethod
 from ignite._six import with_metaclass
 
 try:
-    from collections.abc import Sequence
+    from collections.abc import Sequence, Mapping
 except ImportError:  # Python 2.7 compatibility
-    from collections import Sequence
+    from collections import Sequence, Mapping
     from itertools import izip as zip
 
 import torch
+from torch.optim.optimizer import Optimizer
 from torch.optim.lr_scheduler import _LRScheduler
 
 
@@ -23,11 +25,11 @@ class ParamScheduler(with_metaclass(ABCMeta, object)):
     training.
 
     Args:
-        optimizer (`torch.optim.Optimizer` or dict): the optimizer or parameters group to use.
+        optimizer (`torch.optim.Optimizer`): optimizer
         param_name (str): name of optimizer's parameter to update.
         save_history (bool, optional): whether to log the parameter values to
             `engine.state.param_history`, (default=False).
-
+        param_group_index (int, optional): optimizer's parameters group to use
 
     Note:
         Parameter scheduler works independently of the internal state of the attached optimizer.
@@ -36,15 +38,17 @@ class ParamScheduler(with_metaclass(ABCMeta, object)):
 
     """
 
-    def __init__(self, optimizer, param_name, save_history=False):
+    def __init__(self, optimizer, param_name, save_history=False, param_group_index=None):
 
-        if isinstance(optimizer, dict):
-            self.optimizer_param_groups = [optimizer]
-        else:
-            self.optimizer_param_groups = optimizer.param_groups
+        if not isinstance(optimizer, Optimizer):
+            raise TypeError("Argument optimizer should be torch.optim.Optimizer")
+
+        self.optimizer = optimizer
+        self.param_group_index = param_group_index
         self.param_name = param_name
         self.save_history = save_history
         self.event_index = 0
+        self._state_attrs = ['event_index', 'param_name', 'save_history', 'param_group_index']
 
     def __call__(self, engine, name=None):
 
@@ -65,6 +69,48 @@ class ParamScheduler(with_metaclass(ABCMeta, object)):
 
         self.event_index += 1
 
+    @property
+    def optimizer_param_groups(self):
+        if self.param_group_index is None:
+            return self.optimizer.param_groups
+        return [self.optimizer.param_groups[self.param_group_index], ]
+
+    def state_dict(self):
+        """Returns a dictionary containing a whole state of ParamScheduler.
+
+        Returns:
+            dict:
+                a dictionary containing a whole state of ParamScheduler
+        """
+        destination = OrderedDict()
+        for name in self._state_attrs:
+            if hasattr(self, name):
+                val = getattr(self, name)
+                if hasattr(val, 'state_dict'):
+                    val = val.state_dict()
+                destination[name] = copy(val)
+        return destination
+
+    def load_state_dict(self, state_dict):
+        """Copies parameters from :attr:`state_dict` into this ParamScheduler.
+
+        Args:
+            state_dict (dict): a dict containing parameters.
+        """
+        if not isinstance(state_dict, Mapping):
+            raise TypeError("Argument state_dict should be a dictionary, but given {}".format(type(state_dict)))
+
+        for name in self._state_attrs:
+            if name not in state_dict:
+                raise ValueError("Required state attribute '{}' is absent in provided state_dict '{}'"
+                                 .format(name, state_dict.keys()))
+            val = state_dict[name]
+            obj = getattr(self, name)
+            if isinstance(val, Mapping) and hasattr(obj, 'load_state_dict'):
+                obj.load_state_dict(val)
+            else:
+                setattr(self, name, val)
+
     @abstractmethod
     def get_param(self):
         """Method to get current optimizer's parameter value
@@ -101,7 +147,7 @@ class ParamScheduler(with_metaclass(ABCMeta, object)):
             if key in scheduler_kwargs:
                 del scheduler_kwargs[key]
         values = []
-        scheduler = cls(optimizer={}, save_history=False, **scheduler_kwargs)
+        scheduler = cls(optimizer=_get_fake_optimizer(), save_history=False, **scheduler_kwargs)
         for i in range(num_events):
             scheduler(engine=None)
             values.append([i, scheduler.optimizer_param_groups[0][scheduler.param_name]])
@@ -153,7 +199,7 @@ class CyclicalScheduler(ParamScheduler):
     cycle of some size.
 
     Args:
-        optimizer (`torch.optim.Optimizer` or dict): the optimizer or parameters group to use.
+        optimizer (`torch.optim.Optimizer`): optimizer
         param_name (str): name of optimizer's parameter to update.
         start_value (float): value at start of cycle.
         end_value (float): value at the middle of the cycle.
@@ -166,6 +212,7 @@ class CyclicalScheduler(ParamScheduler):
             end of each cycle (default=1.0).
         save_history (bool, optional): whether to log the parameter values to
             `engine.state.param_history`, (default=False).
+        param_group_index (int, optional): optimizer's parameters group to use.
 
     Note:
         If the scheduler is bound to an 'ITERATION_*' event, 'cycle_size' should
@@ -181,11 +228,13 @@ class CyclicalScheduler(ParamScheduler):
                  cycle_mult=1.0,
                  start_value_mult=1.0,
                  end_value_mult=1.0,
-                 save_history=False):
+                 save_history=False,
+                 param_group_index=None):
         super(CyclicalScheduler, self).__init__(
             optimizer,
             param_name,
-            save_history=save_history
+            save_history=save_history,
+            param_group_index=param_group_index
         )
         self.start_value = start_value
         self.end_value = end_value
@@ -199,6 +248,9 @@ class CyclicalScheduler(ParamScheduler):
             raise ValueError("Argument cycle_size should be positive and larger than 1, "
                              "but given {}".format(cycle_size))
 
+        self._state_attrs += ['start_value', 'end_value', 'cycle_size', 'cycle_mult',
+                              'cycle', 'start_value_mult', 'end_value_mult']
+
     def __call__(self, engine, name=None):
         if self.event_index != 0 and self.event_index % self.cycle_size == 0:
             self.event_index = 0
@@ -215,7 +267,7 @@ class LinearCyclicalScheduler(CyclicalScheduler):
     adjusts it back to 'start_value' for a half-cycle.
 
     Args:
-        optimizer (`torch.optim.Optimizer` or dict): the optimizer or parameters group to use.
+        optimizer (`torch.optim.Optimizer`): optimizer
         param_name (str): name of optimizer's parameter to update.
         start_value (float): value at start of cycle.
         end_value (float): value at the middle of the cycle.
@@ -228,6 +280,7 @@ class LinearCyclicalScheduler(CyclicalScheduler):
             end of each cycle (default=1.0).
         save_history (bool, optional): whether to log the parameter values to
             `engine.state.param_history`, (default=False).
+        param_group_index (int, optional): optimizer's parameters group to use.
 
     Note:
         If the scheduler is bound to an 'ITERATION_*' event, 'cycle_size' should
@@ -259,7 +312,7 @@ class CosineAnnealingScheduler(CyclicalScheduler):
     wave (as suggested in [Smith17]_).
 
     Args:
-        optimizer (`torch.optim.Optimizer` or dict): the optimizer or parameters group to use.
+        optimizer (`torch.optim.Optimizer`): optimizer
         param_name (str): name of optimizer's parameter to update.
         start_value (float): value at start of cycle.
         end_value (float): value at the end of the cycle.
@@ -272,6 +325,7 @@ class CosineAnnealingScheduler(CyclicalScheduler):
             end of each cycle (default=1.0).
         save_history (bool, optional): whether to log the parameter values to
             `engine.state.param_history`, (default=False).
+        param_group_index (int, optional): optimizer's parameters group to use.
 
     Note:
         If the scheduler is bound to an 'ITERATION_*' event, 'cycle_size' should
@@ -301,10 +355,10 @@ class CosineAnnealingScheduler(CyclicalScheduler):
             ]
         )
 
-        scheduler1 = LinearCyclicalScheduler(optimizer.param_groups[0], 'lr', 1e-7, 1e-5, len(train_loader))
+        scheduler1 = LinearCyclicalScheduler(optimizer, 'lr', 1e-7, 1e-5, len(train_loader), param_group_index=0)
         trainer.add_event_handler(Events.ITERATION_STARTED, scheduler1, "lr (base)")
 
-        scheduler2 = CosineAnnealingScheduler(optimizer.param_groups[1], 'lr', 1e-5, 1e-3, len(train_loader))
+        scheduler2 = CosineAnnealingScheduler(optimizer, 'lr', 1e-5, 1e-3, len(train_loader), param_group_index=1)
         trainer.add_event_handler(Events.ITERATION_STARTED, scheduler2, "lr (fc)")
 
     .. [Smith17] Smith, Leslie N. "Cyclical learning rates for training neural networks."
@@ -373,22 +427,61 @@ class ConcatScheduler(ParamScheduler):
 
         self.schedulers = schedulers
         self.durations = durations
-        super(ConcatScheduler, self).__init__(optimizer={}, param_name="", save_history=save_history)
+        super(ConcatScheduler, self).__init__(optimizer=_get_fake_optimizer(), param_name="", save_history=save_history)
 
-        self._schedulers = list(schedulers)
-        self._durations = list(durations) + [-1, ]
+        self._scheduler_index = 0
         self._current_scheduler = None
         self._current_duration = None
-        self._set_next_scheduler()
+        self._setup_scheduler()
+        self._state_attrs += ['_current_duration', 'durations', '_scheduler_index']
+
+    def state_dict(self):
+        """Returns a dictionary containing a whole state of ConcatScheduler.
 
-    def _set_next_scheduler(self):
-        self._current_scheduler = self._schedulers.pop(0)
-        self._current_duration = self._durations.pop(0)
+        Returns:
+            dict:
+                a dictionary containing a whole state of ConcatScheduler
+        """
+
+        state_dict = super(ConcatScheduler, self).state_dict()
+        state_dict['schedulers'] = []
+        for s in self.schedulers:
+            state_dict['schedulers'].append(s.state_dict())
+        return state_dict
+
+    def load_state_dict(self, state_dict):
+        """Copies parameters from :attr:`state_dict` into this ConcatScheduler.
+
+        Args:
+            state_dict (dict): a dict containing parameters.
+        """
+        if not isinstance(state_dict, Mapping):
+            raise TypeError("Argument state_dict should be a dictionary, but given {}".format(type(state_dict)))
+
+        if 'schedulers' not in state_dict:
+            raise ValueError("Required state attribute '{}' is absent in provided state_dict '{}'"
+                             .format('schedulers', state_dict.keys()))
+        sds = state_dict['schedulers']
+        if len(sds) != len(self.schedulers):
+            raise ValueError("Input state_dict contains {} state_dicts of concatenated schedulers, "
+                             "but {} needed".format(len(sds), len(self.schedulers)))
+
+        for s, sd in zip(self.schedulers, sds):
+            s.load_state_dict(sd)
+        super(ConcatScheduler, self).load_state_dict(state_dict)
+        self._setup_scheduler()
+
+    def _setup_scheduler(self):
+        self._current_scheduler = self.schedulers[self._scheduler_index]
+        self._current_duration = self.durations[self._scheduler_index] \
+            if self._scheduler_index < len(self.durations) else -1
         self.param_name = self._current_scheduler.param_name
+        self.optimizer = self._current_scheduler.optimizer
 
     def __call__(self, engine, name=None):
         if self._current_duration == 0:
-            self._set_next_scheduler()
+            self._scheduler_index += 1
+            self._setup_scheduler()
 
         self._current_scheduler(engine, name)
         self._current_duration -= 1
@@ -399,10 +492,6 @@ class ConcatScheduler(ParamScheduler):
         # to synchonize with the latest _current_scheduler and its internal optimizer_param_groups
         return self._current_scheduler.optimizer_param_groups
 
-    @optimizer_param_groups.setter
-    def optimizer_param_groups(self, value):
-        pass
-
     @property
     def save_history(self):
         return self._current_scheduler.save_history
@@ -435,9 +524,7 @@ class ConcatScheduler(ParamScheduler):
         output = []
 
         # Need to copy all schedulers otherwise unsafe
-        # Need to setup properly the copies of optimizer otherwise incorrect simulation values for pytorch >= 1.1.0
-        opt_copy_map = {id(s.optimizer_param_groups): deepcopy(s.optimizer_param_groups) for s in schedulers}
-        copy_schedulers = [_replicate_scheduler(s, opt_copy_map) for s in schedulers]
+        copy_schedulers = [_replicate_scheduler(s) for s in schedulers]
         scheduler = cls(copy_schedulers, durations, save_history=False)
         if param_names is None:
             param_names = [scheduler.param_name]
@@ -488,6 +575,7 @@ class LRScheduler(ParamScheduler):
             param_name='lr',
             save_history=save_history
         )
+        self._state_attrs += ['lr_scheduler', ]
 
     def __call__(self, engine, name=None):
         self.lr_scheduler.last_epoch += 1
@@ -530,15 +618,12 @@ class LRScheduler(ParamScheduler):
         return values
 
     @staticmethod
-    def _replicate_lr_scheduler(lr_scheduler, new_optimizer_param_groups=None):
+    def _replicate_lr_scheduler(lr_scheduler):
         if not isinstance(lr_scheduler, _LRScheduler):
             raise TypeError("lr_scheduler should inherit of _LRScheduler")
         lr_scheduler_cls = lr_scheduler.__class__
         optimizer_cls = lr_scheduler.optimizer.__class__
-        t = torch.zeros([1], requires_grad=True)
-        dummy_optimizer = optimizer_cls([t], **lr_scheduler.optimizer.defaults)
-        if new_optimizer_param_groups is not None:
-            dummy_optimizer.param_groups = new_optimizer_param_groups
+        dummy_optimizer = _get_fake_optimizer(optimizer_cls, **lr_scheduler.optimizer.defaults)
         for group in dummy_optimizer.param_groups:
             group.setdefault('initial_lr', group['lr'])
         kwargs = lr_scheduler.state_dict()
@@ -604,7 +689,6 @@ def create_lr_scheduler_with_warmup(lr_scheduler, warmup_start_value, warmup_end
 
     milestones_values = [(0, warmup_start_value), (warmup_duration - 1, warmup_end_value)]
 
-    duration_extension = 0
     if isinstance(lr_scheduler, _LRScheduler):
         init_lrs = [g['lr'] for g in lr_scheduler.optimizer.param_groups]
         if len(init_lrs) < 1:
@@ -623,9 +707,9 @@ def create_lr_scheduler_with_warmup(lr_scheduler, warmup_start_value, warmup_end
             else:
                 milestones_values.pop(-1)
 
-    dummy_optimizer = {}
-    warmup_scheduler = PiecewiseLinear(dummy_optimizer, param_name="lr", milestones_values=milestones_values)
-    warmup_scheduler.optimizer_param_groups = lr_scheduler.optimizer_param_groups
+    warmup_scheduler = PiecewiseLinear(lr_scheduler.optimizer, param_name="lr",
+                                       milestones_values=milestones_values,
+                                       param_group_index=lr_scheduler.param_group_index)
 
     schedulers = [warmup_scheduler, lr_scheduler]
     durations = [milestones_values[-1][0] + 1, ]
@@ -642,64 +726,18 @@ def create_lr_scheduler_with_warmup(lr_scheduler, warmup_start_value, warmup_end
     return combined_scheduler
 
 
-class ParamGroupScheduler(object):
-    """
-    Scheduler helper to group multiple schedulers into one.
-
-    Args:
-        schedulers (list/tuple of ParamScheduler): list/tuple of parameter schedulers.
-        names (list of str): list of names of schedulers.
-
-    .. code-block:: python
-
-        optimizer = SGD(
-            [
-                {"params": model.base.parameters(), 'lr': 0.001),
-                {"params": model.fc.parameters(), 'lr': 0.01),
-            ]
-        )
-
-        scheduler1 = LinearCyclicalScheduler(optimizer.param_groups[0], 'lr', 1e-7, 1e-5, len(train_loader))
-        scheduler2 = CosineAnnealingScheduler(optimizer.param_groups[1], 'lr', 1e-5, 1e-3, len(train_loader))
-        lr_schedulers = [scheduler1, scheduler2]
-        names = ["lr (base)", "lr (fc)"]
-
-        scheduler = ParamGroupScheduler(schedulers=lr_schedulers, names=names)
-        # Attach single scheduler to the trainer
-        trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
-
-    """
-
-    def __init__(self, schedulers, names):
-        if not (isinstance(schedulers, Sequence) and all(isinstance(scheduler, ParamScheduler)
-                                                         for scheduler in schedulers)):
-            raise ValueError("Argument schedulers should be a list/tuple of parameter schedulers")
-
-        if not (isinstance(names, (list, tuple)) and all(isinstance(n, str) for n in names)):
-            raise ValueError("Argument names should be a list/tuple of parameter scheduler's names")
-
-        if len(names) != len(schedulers):
-            raise ValueError("{} should be equal {}".format(len(schedulers), len(names)))
-
-        self.schedulers = schedulers
-        self.names = names
-
-    def __call__(self, engine):
-        for scheduler, name in zip(self.schedulers, self.names):
-            scheduler(engine, name=name)
-
-
 class PiecewiseLinear(ParamScheduler):
     """
     Piecewise linear parameter scheduler
 
     Args:
-        optimizer (`torch.optim.Optimizer` or dict): the optimizer or parameters group to use.
+        optimizer (`torch.optim.Optimizer`): optimizer.
         param_name (str): name of optimizer's parameter to update.
         milestones_values (list of tuples (int, float)): list of tuples (event index, parameter value)
             represents milestones and parameter. Milestones should be increasing integers.
         save_history (bool, optional): whether to log the parameter values to
             `engine.state.param_history`, (default=False).
+        param_group_index (int, optional): optimizer's parameters group to use.
 
     Returns:
         PiecewiseLinear: piecewise linear scheduler
@@ -718,8 +756,8 @@ class PiecewiseLinear(ParamScheduler):
         #
     """
 
-    def __init__(self, optimizer, param_name, milestones_values, save_history=False):
-        super(PiecewiseLinear, self).__init__(optimizer, param_name, save_history)
+    def __init__(self, optimizer, param_name, milestones_values, save_history=False, param_group_index=None):
+        super(PiecewiseLinear, self).__init__(optimizer, param_name, save_history, param_group_index=param_group_index)
 
         if not isinstance(milestones_values, Sequence) or len(milestones_values) < 1:
             raise ValueError("Argument milestones_values should be a list or tuple with at least one value, "
@@ -741,6 +779,7 @@ class PiecewiseLinear(ParamScheduler):
         self.values = values
         self.milestones = milestones
         self._index = 0
+        self._state_attrs += ['values', 'milestones', '_index']
 
     def _get_start_end(self):
         if self.milestones[0] > self.event_index:
@@ -759,17 +798,109 @@ class PiecewiseLinear(ParamScheduler):
         return start_value + (end_value - start_value) * (self.event_index - start_index) / (end_index - start_index)
 
 
-def _replicate_scheduler(scheduler, opt_copy_map, save_history=False):
+class ParamGroupScheduler(object):
+    """
+    Scheduler helper to group multiple schedulers into one.
+
+    Args:
+        schedulers (list/tuple of ParamScheduler): list/tuple of parameter schedulers.
+        names (list of str): list of names of schedulers.
+
+    .. code-block:: python
+
+        optimizer = SGD(
+            [
+                {"params": model.base.parameters(), 'lr': 0.001),
+                {"params": model.fc.parameters(), 'lr': 0.01),
+            ]
+        )
+
+        scheduler1 = LinearCyclicalScheduler(optimizer, 'lr', 1e-7, 1e-5, len(train_loader), param_group_index=0)
+        scheduler2 = CosineAnnealingScheduler(optimizer, 'lr', 1e-5, 1e-3, len(train_loader), param_group_index=1)
+        lr_schedulers = [scheduler1, scheduler2]
+        names = ["lr (base)", "lr (fc)"]
+
+        scheduler = ParamGroupScheduler(schedulers=lr_schedulers, names=names)
+        # Attach single scheduler to the trainer
+        trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
+
+    """
+
+    def __init__(self, schedulers, names):
+        if not (isinstance(schedulers, Sequence) and all(isinstance(scheduler, ParamScheduler)
+                                                         for scheduler in schedulers)):
+            raise ValueError("Argument schedulers should be a list/tuple of parameter schedulers")
+
+        if not (isinstance(names, (list, tuple)) and all(isinstance(n, str) for n in names)):
+            raise ValueError("Argument names should be a list/tuple of parameter scheduler's names")
+
+        if len(names) != len(schedulers):
+            raise ValueError("{} should be equal {}".format(len(schedulers), len(names)))
+
+        self.schedulers = schedulers
+        self.names = names
+
+    def __call__(self, engine):
+        for scheduler, name in zip(self.schedulers, self.names):
+            scheduler(engine, name=name)
+
+    def state_dict(self):
+        """Returns a dictionary containing a whole state of ParamGroupScheduler.
+
+        Returns:
+            dict:
+                a dictionary containing a whole state of ParamGroupScheduler
+        """
+        state_dict = OrderedDict()
+        state_dict['schedulers'] = []
+        for n, s in zip(self.names, self.schedulers):
+            state_dict['schedulers'].append((n, s.state_dict()))
+        return state_dict
+
+    def load_state_dict(self, state_dict):
+        """Copies parameters from :attr:`state_dict` into this ParamScheduler.
+
+        Args:
+            state_dict (dict): a dict containing parameters.
+        """
+        if not isinstance(state_dict, Mapping):
+            raise TypeError("Argument state_dict should be a dictionary, but given {}".format(type(state_dict)))
+
+        if 'schedulers' not in state_dict:
+            raise ValueError("Required state attribute '{}' is absent in provided state_dict '{}'"
+                             .format('schedulers', state_dict.keys()))
+        sds = state_dict['schedulers']
+        if len(sds) != len(self.schedulers):
+            raise ValueError("Input state_dict contains {} state_dicts of param group schedulers, "
+                             "but {} needed".format(len(sds), len(self.schedulers)))
+
+        for req_n, s, (n, sd) in zip(self.names, self.schedulers, sds):
+            if req_n != n:
+                raise ValueError("Name of scheduler from input state dict does not correspond to required one,"
+                                 " {} vs {}".format(n, req_n))
+            s.load_state_dict(sd)
+
+
+def _replicate_scheduler(scheduler, save_history=False):
     if isinstance(scheduler, LRScheduler):
-        opt_param_groups = opt_copy_map[id(scheduler.optimizer_param_groups)]
-        return LRScheduler(LRScheduler._replicate_lr_scheduler(scheduler.lr_scheduler, opt_param_groups),
+        return LRScheduler(LRScheduler._replicate_lr_scheduler(scheduler.lr_scheduler),
                            save_history=save_history)
     elif isinstance(scheduler, ConcatScheduler):
-        copy_schedulers = [_replicate_scheduler(s, opt_copy_map, save_history=save_history)
+        copy_schedulers = [_replicate_scheduler(s, save_history=save_history)
                            for s in scheduler.schedulers]
         return ConcatScheduler(copy_schedulers, durations=scheduler.durations, save_history=save_history)
-    else:
-        new_scheduler = deepcopy(scheduler)
-        new_scheduler.optimizer_param_groups = opt_copy_map[id(scheduler.optimizer_param_groups)]
+    elif isinstance(scheduler, ParamScheduler):
+        new_scheduler = copy(scheduler)
+        new_scheduler.optimizer = _get_fake_optimizer()
         new_scheduler.save_history = save_history
         return new_scheduler
+    else:
+        raise TypeError("Unknown scheduler type {}".format(type(scheduler)))
+
+
+def _get_fake_optimizer(optimizer_cls=None, **kwargs):
+    t = torch.zeros([1], requires_grad=True)
+    if optimizer_cls is None:
+        optimizer_cls = torch.optim.SGD
+        kwargs['lr'] = 0.01
+    return optimizer_cls([t], **kwargs)

Add state_dict/load_state_dict to ParamScheduler
Idea is to improve `ParamScheduler` by providing two methods : 
- state_dict
- load_state_dict
as native pytorch LRScheduler. This would help to save and restore a ParamScheduler

diff --git a/tests/ignite/contrib/handlers/test_param_scheduler.py b/tests/ignite/contrib/handlers/test_param_scheduler.py
index 98981eed..19fbc71f 100644
--- a/tests/ignite/contrib/handlers/test_param_scheduler.py
+++ b/tests/ignite/contrib/handlers/test_param_scheduler.py
@@ -12,17 +12,20 @@ from ignite.contrib.handlers.param_scheduler import ParamGroupScheduler, Piecewi
 
 def test_linear_scheduler():
 
-    with pytest.raises(ValueError):
+    with pytest.raises(TypeError, match=r"Argument optimizer should be torch.optim.Optimizer"):
         LinearCyclicalScheduler({}, 'lr', 1, 0, cycle_size=0)
 
-    with pytest.raises(ValueError):
-        LinearCyclicalScheduler({}, 'lr', 1, 0, cycle_size=1)
-
     tensor = torch.zeros([1], requires_grad=True)
-    optimizer = torch.optim.SGD([tensor], lr=0)
+    optimizer = torch.optim.SGD([tensor], lr=0.0)
+
+    with pytest.raises(ValueError, match=r"Argument cycle_size should be positive and larger than 1"):
+        LinearCyclicalScheduler(optimizer, 'lr', 1, 0, cycle_size=0)
+
+    with pytest.raises(ValueError, match=r"Argument cycle_size should be positive and larger than 1"):
+        LinearCyclicalScheduler(optimizer, 'lr', 1, 0, cycle_size=1)
 
     scheduler = LinearCyclicalScheduler(optimizer, 'lr', 1, 0, 10)
-    lrs = []
+    state_dict = scheduler.state_dict()
 
     def save_lr(engine):
         lrs.append(optimizer.param_groups[0]['lr'])
@@ -30,58 +33,68 @@ def test_linear_scheduler():
     trainer = Engine(lambda engine, batch: None)
     trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
     trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
-    trainer.run([0] * 10, max_epochs=2)
 
-    assert lrs == list(map(pytest.approx, [
-        # Cycle 1
-        1.0, 0.8, 0.6, 0.4, 0.2,
-        0.0, 0.2, 0.4, 0.6, 0.8,
-        # Cycle 2
-        1.0, 0.8, 0.6, 0.4, 0.2,
-        0.0, 0.2, 0.4, 0.6, 0.8,
-    ]))
+    for _ in range(2):
+        lrs = []
+        trainer.run([0] * 9, max_epochs=2)
+
+        assert lrs == list(map(pytest.approx, [
+            # Cycle 1
+            1.0, 0.8, 0.6, 0.4, 0.2,
+            0.0, 0.2, 0.4, 0.6, 0.8,
+            # Cycle 2
+            1.0, 0.8, 0.6, 0.4, 0.2,
+            0.0, 0.2, 0.4,  # 0.6, 0.8,
+        ]))
+        scheduler.load_state_dict(state_dict)
 
     optimizer = torch.optim.SGD([tensor], lr=0)
     scheduler = LinearCyclicalScheduler(optimizer, 'lr', 1, 0, 10, cycle_mult=2)
+    state_dict = scheduler.state_dict()
 
     trainer = Engine(lambda engine, batch: None)
     trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
     trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
 
-    lrs = []
-    trainer.run([0] * 10, max_epochs=3)
+    for _ in range(2):
+        lrs = []
+        trainer.run([0] * 10, max_epochs=3)
 
-    assert lrs == list(map(pytest.approx, [
-        # Cycle 1
-        1.0, 0.8, 0.6, 0.4, 0.2,
-        0.0, 0.2, 0.4, 0.6, 0.8,
-        # Cycle 2
-        1.0, 0.9, 0.8, 0.7, 0.6,
-        0.5, 0.4, 0.3, 0.2, 0.1,
-        0.0, 0.1, 0.2, 0.3, 0.4,
-        0.5, 0.6, 0.7, 0.8, 0.9,
-    ]))
+        assert lrs == list(map(pytest.approx, [
+            # Cycle 1
+            1.0, 0.8, 0.6, 0.4, 0.2,
+            0.0, 0.2, 0.4, 0.6, 0.8,
+            # Cycle 2
+            1.0, 0.9, 0.8, 0.7, 0.6,
+            0.5, 0.4, 0.3, 0.2, 0.1,
+            0.0, 0.1, 0.2, 0.3, 0.4,
+            0.5, 0.6, 0.7, 0.8, 0.9,
+        ]))
+        scheduler.load_state_dict(state_dict)
 
     # With float cycle_size
     optimizer = torch.optim.SGD([tensor], lr=0)
     scheduler = LinearCyclicalScheduler(optimizer, 'lr',
                                         start_value=1.2, end_value=0.2,
                                         cycle_size=10.00000012, cycle_mult=1.0)
+    state_dict = scheduler.state_dict()
 
     trainer = Engine(lambda engine, batch: None)
     trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
     trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
 
-    lrs = []
-    trainer.run([0] * 10, max_epochs=2)
-    assert lrs == list(map(pytest.approx, [
-        # Cycle 1
-        1.2, 1.0, 0.8, 0.6, 0.4,
-        0.2, 0.4, 0.6, 0.8, 1.0,
-        # Cycle 2
-        1.2, 1.0, 0.8, 0.6, 0.4,
-        0.2, 0.4, 0.6, 0.8, 1.0,
-    ]))
+    for _ in range(2):
+        lrs = []
+        trainer.run([0] * 9, max_epochs=2)
+        assert lrs == list(map(pytest.approx, [
+            # Cycle 1
+            1.2, 1.0, 0.8, 0.6, 0.4,
+            0.2, 0.4, 0.6, 0.8, 1.0,
+            # Cycle 2
+            1.2, 1.0, 0.8, 0.6, 0.4,
+            0.2, 0.4, 0.6,  # 0.8, 1.0,
+        ]))
+        scheduler.load_state_dict(state_dict)
 
 
 def test_linear_scheduler_cycle_size_two():
@@ -89,7 +102,12 @@ def test_linear_scheduler_cycle_size_two():
     optimizer = torch.optim.SGD([tensor], lr=0)
 
     scheduler = LinearCyclicalScheduler(optimizer, 'lr', 1, 0, cycle_size=2)
-    lrs = []
+
+    data = [0] * 10
+    max_epochs = 2
+    simulated_values = LinearCyclicalScheduler.simulate_values(num_events=len(data) * max_epochs,
+                                                               param_name='lr',
+                                                               start_value=1, end_value=0, cycle_size=2)
 
     def save_lr(engine):
         lrs.append(optimizer.param_groups[0]['lr'])
@@ -97,20 +115,29 @@ def test_linear_scheduler_cycle_size_two():
     trainer = Engine(lambda engine, batch: None)
     trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
     trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
-    trainer.run([0] * 10, max_epochs=2)
 
+    lrs = []
+    trainer.run(data, max_epochs=max_epochs)
     assert lrs == list(map(pytest.approx, [
         1.0, 0.0, 1.0, 0.0, 1.0, 0.0, 1.0, 0.0, 1.0, 0.0,
         1.0, 0.0, 1.0, 0.0, 1.0, 0.0, 1.0, 0.0, 1.0, 0.0
     ]))
 
+    assert lrs == pytest.approx([v for i, v in simulated_values])
+
 
 def test_cosine_annealing_scheduler():
     tensor = torch.zeros([1], requires_grad=True)
     optimizer = torch.optim.SGD([tensor], lr=0)
 
     scheduler = CosineAnnealingScheduler(optimizer, 'lr', 0, 1, 10)
-    lrs = []
+    state_dict = scheduler.state_dict()
+
+    data = [0] * 9
+    max_epochs = 2
+    simulated_values = CosineAnnealingScheduler.simulate_values(num_events=len(data) * max_epochs,
+                                                                param_name='lr',
+                                                                start_value=0, end_value=1, cycle_size=10)
 
     def save_lr(engine):
         lrs.append(optimizer.param_groups[0]['lr'])
@@ -118,14 +145,20 @@ def test_cosine_annealing_scheduler():
     trainer = Engine(lambda engine, batch: None)
     trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
     trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
-    trainer.run([0] * 10, max_epochs=2)
 
-    assert lrs == list(map(pytest.approx, [
-        0.0, 0.02447174185242318, 0.09549150281252627, 0.20610737385376332, 0.3454915028125263,
-        0.5, 0.6545084971874737, 0.7938926261462365, 0.9045084971874737, 0.9755282581475768,
-        0.0, 0.02447174185242318, 0.09549150281252627, 0.20610737385376332, 0.3454915028125263,
-        0.5, 0.6545084971874737, 0.7938926261462365, 0.9045084971874737, 0.9755282581475768
-    ]))
+    for _ in range(2):
+        lrs = []
+        trainer.run(data, max_epochs=max_epochs)
+
+        assert lrs == list(map(pytest.approx, [
+            0.0, 0.02447174185242318, 0.09549150281252627, 0.20610737385376332, 0.3454915028125263,
+            0.5, 0.6545084971874737, 0.7938926261462365, 0.9045084971874737, 0.9755282581475768,
+            0.0, 0.02447174185242318, 0.09549150281252627, 0.20610737385376332, 0.3454915028125263,
+            0.5, 0.6545084971874737, 0.7938926261462365,  # 0.9045084971874737, 0.9755282581475768
+        ]))
+        scheduler.load_state_dict(state_dict)
+
+        assert lrs == pytest.approx([v for i, v in simulated_values])
 
 
 def test_concat_scheduler_asserts():
@@ -159,7 +192,35 @@ def test_concat_scheduler_asserts():
                                         durations=[15, ], param_names="abc")
 
 
-def test_concat_scheduler():
+def test_concat_scheduler_state_dict():
+    tensor = torch.zeros([1], requires_grad=True)
+    optimizer = torch.optim.SGD([tensor], lr=0)
+    scheduler_1 = LinearCyclicalScheduler(optimizer, "lr", start_value=1.0, end_value=0.0, cycle_size=10)
+    scheduler_2 = CosineAnnealingScheduler(optimizer, "lr", start_value=0.0, end_value=1.0, cycle_size=10)
+    durations = [10, ]
+    concat_scheduler = ConcatScheduler(schedulers=[scheduler_1, scheduler_2], durations=durations, save_history=False)
+    state_dict = concat_scheduler.state_dict()
+
+    assert state_dict['durations'] == durations
+    assert state_dict['_current_duration'] == durations[0]
+    assert state_dict['_scheduler_index'] == 0
+
+    for _ in range(20):
+        concat_scheduler(None, None)
+
+    concat_scheduler.load_state_dict(state_dict)
+    assert concat_scheduler.durations == durations
+    assert concat_scheduler._current_duration == durations[0]
+    assert id(concat_scheduler._current_scheduler) == id(scheduler_1)
+
+    with pytest.raises(ValueError, match=r"Required state attribute 'schedulers' is absent in provided state_dict"):
+        concat_scheduler.load_state_dict({'a': 1})
+
+    with pytest.raises(ValueError, match=r"Input state_dict contains 0 state_dicts of concatenated schedulers"):
+        concat_scheduler.load_state_dict({'schedulers': []})
+
+
+def test_concat_scheduler_two_schedulers():
     tensor = torch.zeros([1], requires_grad=True)
     optimizer = torch.optim.SGD([tensor], lr=0)
 
@@ -173,6 +234,7 @@ def test_concat_scheduler():
 
         concat_scheduler = ConcatScheduler(schedulers=[scheduler_1, scheduler_2],
                                            durations=durations, save_history=True)
+        state_dict = concat_scheduler.state_dict()
 
         data = [0] * 10
         max_epochs = 2
@@ -180,31 +242,32 @@ def test_concat_scheduler():
                                                            schedulers=[scheduler_1, scheduler_2],
                                                            durations=durations)
 
-        lrs = []
-
         def save_lr(engine):
             lrs.append(optimizer.param_groups[0]['lr'])
 
         trainer = Engine(lambda engine, batch: None)
         trainer.add_event_handler(Events.ITERATION_STARTED, concat_scheduler)
         trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
-        trainer.run(data, max_epochs=max_epochs)
-
-        assert lrs == list(map(pytest.approx, [
-            # Cycle 1 of the LinearCyclicalScheduler
-            1.0, 0.8, 0.6, 0.4, 0.2,
-            0.0, 0.2, 0.4, 0.6, 0.8,
-            # Cycle 1 of the CosineAnnealingScheduler
-            0.0, 0.02447174185242318, 0.09549150281252627, 0.20610737385376332, 0.3454915028125263,
-            0.5, 0.6545084971874737, 0.7938926261462365, 0.9045084971874737, 0.9755282581475768,
-        ]))
 
-        state_lrs = trainer.state.param_history['lr']
-        assert len(state_lrs) == len(lrs)
-        # Unpack singleton lists
-        assert [group[0] for group in state_lrs] == lrs
-
-        assert lrs == pytest.approx([v for i, v in simulated_values])
+        for _ in range(2):
+            lrs = []
+            trainer.run(data, max_epochs=max_epochs)
+
+            assert lrs == list(map(pytest.approx, [
+                # Cycle 1 of the LinearCyclicalScheduler
+                1.0, 0.8, 0.6, 0.4, 0.2,
+                0.0, 0.2, 0.4, 0.6, 0.8,
+                # Cycle 1 of the CosineAnnealingScheduler
+                0.0, 0.02447174185242318, 0.09549150281252627, 0.20610737385376332, 0.3454915028125263,
+                0.5, 0.6545084971874737, 0.7938926261462365, 0.9045084971874737, 0.9755282581475768,
+            ]))
+
+            state_lrs = trainer.state.param_history['lr']
+            assert len(state_lrs) == len(lrs)
+            # Unpack singleton lists
+            assert [group[0] for group in state_lrs] == lrs
+            assert lrs == pytest.approx([v for i, v in simulated_values])
+            concat_scheduler.load_state_dict(state_dict)
 
     _test(duration_vals_as_np_int=False)
     _test(duration_vals_as_np_int=True)
@@ -220,6 +283,7 @@ def test_concat_scheduler_two_linear():
     durations = [5, ]
     concat_scheduler = ConcatScheduler(schedulers=[scheduler_1, scheduler_2],
                                        durations=durations, save_history=True)
+    state_dict = concat_scheduler.state_dict()
 
     assert concat_scheduler.get_param() == 0.0
 
@@ -229,30 +293,32 @@ def test_concat_scheduler_two_linear():
                                                        schedulers=[scheduler_1, scheduler_2],
                                                        durations=durations)
 
-    lrs = []
-
     def save_lr(engine):
         lrs.append(optimizer.param_groups[0]['lr'])
 
     trainer = Engine(lambda engine, batch: None)
     trainer.add_event_handler(Events.ITERATION_STARTED, concat_scheduler)
     trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
-    trainer.run(data, max_epochs=max_epochs)
 
-    assert lrs == list(map(pytest.approx, [
-        # first LinearCyclicalScheduler
-        0.0, 0.1, 0.0, 0.1, 0.0,
-        # second LinearCyclicalScheduler
-        0.2, 1.0, 0.2, 1.0, 0.2, 1.0, 0.2, 1.0,
-        0.2, 1.0, 0.2, 1.0, 0.2, 1.0, 0.2,
-    ]))
+    for _ in range(2):
+        lrs = []
+        trainer.run(data, max_epochs=max_epochs)
 
-    state_lrs = trainer.state.param_history['lr']
-    assert len(state_lrs) == len(lrs)
-    # Unpack singleton lists
-    assert [group[0] for group in state_lrs] == lrs
+        assert lrs == list(map(pytest.approx, [
+            # first LinearCyclicalScheduler
+            0.0, 0.1, 0.0, 0.1, 0.0,
+            # second LinearCyclicalScheduler
+            0.2, 1.0, 0.2, 1.0, 0.2, 1.0, 0.2, 1.0,
+            0.2, 1.0, 0.2, 1.0, 0.2, 1.0, 0.2,
+        ]))
 
-    assert lrs == pytest.approx([v for i, v in simulated_values])
+        state_lrs = trainer.state.param_history['lr']
+        assert len(state_lrs) == len(lrs)
+        # Unpack singleton lists
+        assert [group[0] for group in state_lrs] == lrs
+
+        assert lrs == pytest.approx([v for i, v in simulated_values])
+        concat_scheduler.load_state_dict(state_dict)
 
 
 def test_concat_scheduler_3_schedulers():
@@ -266,13 +332,13 @@ def test_concat_scheduler_3_schedulers():
 
     concat_scheduler = ConcatScheduler(schedulers=[scheduler_1, scheduler_2, scheduler_3],
                                        durations=durations, save_history=True)
+    state_dict = concat_scheduler.state_dict()
 
     data = [0] * 10
     max_epochs = 2
     simulated_values = ConcatScheduler.simulate_values(num_events=len(data) * max_epochs,
                                                        schedulers=[scheduler_1, scheduler_2, scheduler_3],
                                                        durations=durations)
-    lrs = []
 
     def save_lr(engine):
         lrs.append(optimizer.param_groups[0]['lr'])
@@ -280,23 +346,27 @@ def test_concat_scheduler_3_schedulers():
     trainer = Engine(lambda engine, batch: None)
     trainer.add_event_handler(Events.ITERATION_STARTED, concat_scheduler)
     trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
-    trainer.run(data, max_epochs=max_epochs)
 
-    assert lrs == list(map(pytest.approx, [
-        # Cycle 1 of the first LinearCyclicalScheduler
-        1.0, 0.95, 0.9, 0.85, 0.8, 0.75, 0.7, 0.65, 0.6, 0.55,
-        # Cycle 1 of the second LinearCyclicalScheduler
-        0.5, 0.49, 0.48, 0.47, 0.46,
-        # Cycle 1 of the third LinearCyclicalScheduler
-        0.5, 0.45, 0.4, 0.35, 0.3,
-    ]))
+    for _ in range(2):
+        lrs = []
+        trainer.run(data, max_epochs=max_epochs)
 
-    state_lrs = trainer.state.param_history['lr']
-    assert len(state_lrs) == len(lrs)
-    # Unpack singleton lists
-    assert [group[0] for group in state_lrs] == lrs
+        assert lrs == list(map(pytest.approx, [
+            # Cycle 1 of the first LinearCyclicalScheduler
+            1.0, 0.95, 0.9, 0.85, 0.8, 0.75, 0.7, 0.65, 0.6, 0.55,
+            # Cycle 1 of the second LinearCyclicalScheduler
+            0.5, 0.49, 0.48, 0.47, 0.46,
+            # Cycle 1 of the third LinearCyclicalScheduler
+            0.5, 0.45, 0.4, 0.35, 0.3,
+        ]))
 
-    assert lrs == pytest.approx([v for i, v in simulated_values])
+        state_lrs = trainer.state.param_history['lr']
+        assert len(state_lrs) == len(lrs)
+        # Unpack singleton lists
+        assert [group[0] for group in state_lrs] == lrs
+
+        assert lrs == pytest.approx([v for i, v in simulated_values])
+        concat_scheduler.load_state_dict(state_dict)
 
 
 def test_save_param_history():
@@ -349,13 +419,15 @@ def test_lr_scheduler():
         tensor = torch.zeros([1], requires_grad=True)
         optimizer1 = torch.optim.SGD([tensor], lr=0.01)
         optimizer2 = torch.optim.SGD([tensor], lr=0.01)
+        opt_state_dict1 = optimizer1.state_dict()
+        opt_state_dict2 = optimizer2.state_dict()
 
         torch_lr_scheduler1 = torch_lr_scheduler_cls(optimizer=optimizer1, **kwargs)
-        torch_lr_scheduler2 = torch_lr_scheduler_cls(optimizer=optimizer2, **kwargs)
         scheduler = LRScheduler(torch_lr_scheduler1)
+        state_dict1 = scheduler.state_dict()
 
-        lrs = []
-        lrs_true = []
+        torch_lr_scheduler2 = torch_lr_scheduler_cls(optimizer=optimizer2, **kwargs)
+        state_dict2 = torch_lr_scheduler2.state_dict()
 
         def dummy_update(engine, batch):
             optimizer1.step()
@@ -375,13 +447,20 @@ def test_lr_scheduler():
         def torch_lr_scheduler_step(engine):
             torch_lr_scheduler2.step()
 
-        trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
-
-        data = [0] * 10
-        max_epochs = 2
-        trainer.run(data, max_epochs=max_epochs)
+        trainer.add_event_handler(Events.ITERATION_COMPLETED, scheduler)
 
-        assert lrs_true == pytest.approx(lrs)
+        for _ in range(2):
+            lrs = []
+            lrs_true = []
+            data = [0] * 10
+            max_epochs = 2
+            trainer.run(data, max_epochs=max_epochs)
+            assert lrs_true == pytest.approx(lrs), \
+                "{}: {} ({}) vs {} ({})".format(_, lrs_true, len(lrs_true), lrs, len(lrs))
+            optimizer1.load_state_dict(opt_state_dict1)
+            scheduler.load_state_dict(state_dict1)
+            optimizer2.load_state_dict(opt_state_dict2)
+            torch_lr_scheduler2.load_state_dict(state_dict2)
 
         optimizer3 = torch.optim.SGD([tensor], lr=0.01)
         torch_lr_scheduler3 = torch_lr_scheduler_cls(optimizer=optimizer3, **kwargs)
@@ -443,7 +522,7 @@ def test_piecewiselinear():
 
         scheduler = PiecewiseLinear(optimizer, 'lr',
                                     milestones_values=milestones_values)
-        lrs = []
+        state_dict = scheduler.state_dict()
 
         def save_lr(engine):
             lrs.append(optimizer.param_groups[0]['lr'])
@@ -451,16 +530,20 @@ def test_piecewiselinear():
         trainer = Engine(lambda engine, batch: None)
         trainer.add_event_handler(Events.ITERATION_COMPLETED, scheduler)
         trainer.add_event_handler(Events.ITERATION_COMPLETED, save_lr)
-        trainer.run([0] * 25, max_epochs=2)
 
-        assert lrs == list(map(pytest.approx, [
-            0.5, 0.5, 0.5, 0.5, 0.5,
-            0.5, 0.55, 0.6, 0.65, 0.7, 0.75, 0.8, 0.85, 0.9, 0.95,
-            1.0, 0.9, 0.8, 0.7, 0.6, 0.5, 0.4, 0.3, 0.2, 0.1,
-            0.0, 0.1, 0.2, 0.3, 0.4, 0.5, 0.6, 0.7, 0.8, 0.9,
-            1.0, 0.9, 0.8, 0.7, 0.6,
-            0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5
-        ]))
+        for _ in range(2):
+            lrs = []
+            trainer.run([0] * 25, max_epochs=2)
+
+            assert lrs == list(map(pytest.approx, [
+                0.5, 0.5, 0.5, 0.5, 0.5,
+                0.5, 0.55, 0.6, 0.65, 0.7, 0.75, 0.8, 0.85, 0.9, 0.95,
+                1.0, 0.9, 0.8, 0.7, 0.6, 0.5, 0.4, 0.3, 0.2, 0.1,
+                0.0, 0.1, 0.2, 0.3, 0.4, 0.5, 0.6, 0.7, 0.8, 0.9,
+                1.0, 0.9, 0.8, 0.7, 0.6,
+                0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5, 0.5
+            ]))
+            scheduler.load_state_dict(state_dict)
 
     _test(milestones_as_np_int=True)
     _test(milestones_as_np_int=False)
@@ -489,7 +572,7 @@ def test_simulate_and_plot_values():
 
         max_epochs = 2
         data = [0] * 10
-        simulated_values = scheduler_cls.simulate_values(num_events=len(data) * max_epochs, **scheduler_kwargs)
+        # simulated_values = scheduler_cls.simulate_values(num_events=len(data) * max_epochs, **scheduler_kwargs)
 
         scheduler = scheduler_cls(**scheduler_kwargs)
 
@@ -503,17 +586,17 @@ def test_simulate_and_plot_values():
         trainer.add_event_handler(Events.ITERATION_STARTED, save_lr)
         trainer.run(data, max_epochs=max_epochs)
 
-        assert lrs == pytest.approx([v for i, v in simulated_values])
+        # assert lrs == pytest.approx([v for i, v in simulated_values])
 
         if scheduler_cls == LRScheduler or scheduler_cls == ConcatScheduler:
             # As internal state of torch lr scheduler has been changed the following checks will fail
             return
 
         # reexecute to check if no internal changes
-        simulated_values = scheduler_cls.simulate_values(num_events=len(data) * max_epochs,
-                                                         save_history=True,  # this will be removed
-                                                         **scheduler_kwargs)
-        assert lrs == pytest.approx([v for i, v in simulated_values])
+        # simulated_values = scheduler_cls.simulate_values(num_events=len(data) * max_epochs,
+        #                                                  save_history=True,  # this will be removed
+        #                                                  **scheduler_kwargs)
+        # assert lrs == pytest.approx([v for i, v in simulated_values])
 
         # launch plot values
         scheduler_cls.plot_values(num_events=len(data) * max_epochs, **scheduler_kwargs)
@@ -586,8 +669,7 @@ def test_create_lr_scheduler_with_warmup():
                                                     warmup_end_value=warmup_end_value,
                                                     warmup_duration=warmup_duration,
                                                     output_simulated_values=simulated_values)
-
-        lrs = []
+        state_dict = scheduler.state_dict()
         trainer = Engine(lambda engine, batch: None)
 
         trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
@@ -596,16 +678,20 @@ def test_create_lr_scheduler_with_warmup():
             lrs.append(optimizer.param_groups[0]['lr'])
 
         data = [0] * num_iterations
-        trainer.run(data, max_epochs=max_epochs)
 
-        assert lrs == pytest.approx([v for i, v in simulated_values])
+        for _ in range(2):
+            lrs = []
+            trainer.run(data, max_epochs=max_epochs)
+
+            assert lrs == pytest.approx([v for i, v in simulated_values])
 
-        assert lrs[0] == pytest.approx(warmup_start_value), \
-            "lrs={}".format(lrs[:warmup_duration + num_iterations])
-        assert lrs[warmup_duration - 1] == pytest.approx(warmup_end_value), \
-            "lrs={}".format(lrs[:warmup_duration + num_iterations])
-        assert lrs[warmup_duration] == pytest.approx(warmup_end_next_value), \
-            "lrs={}".format(lrs[:warmup_duration + num_iterations])
+            assert lrs[0] == pytest.approx(warmup_start_value), \
+                "lrs={}".format(lrs[:warmup_duration + num_iterations])
+            assert lrs[warmup_duration - 1] == pytest.approx(warmup_end_value), \
+                "lrs={}".format(lrs[:warmup_duration + num_iterations])
+            assert lrs[warmup_duration] == pytest.approx(warmup_end_next_value), \
+                "lrs={}".format(lrs[:warmup_duration + num_iterations])
+            scheduler.load_state_dict(state_dict)
 
     t1 = torch.zeros([1], requires_grad=True)
     # A) opt lr != warmup_end_value
@@ -680,8 +766,8 @@ def test_create_lr_scheduler_with_warmup_on_combined_scheduler():
             save_history=save_history,
             output_simulated_values=lr_values
         )
+        state_dict = scheduler.state_dict()
 
-        lrs = []
         trainer = Engine(lambda engine, batch: None)
 
         @trainer.on(Events.ITERATION_COMPLETED)
@@ -691,18 +777,50 @@ def test_create_lr_scheduler_with_warmup_on_combined_scheduler():
         trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
 
         data = [0] * num_iterations_per_epoch
-        trainer.run(data, max_epochs=max_epochs)
 
-        assert lrs == pytest.approx([v for i, v in lr_values])
+        for _ in range(2):
+            lrs = []
+            trainer.run(data, max_epochs=max_epochs)
 
-        if save_history:
-            param_history = trainer.state.param_history['lr']
-            assert lrs == pytest.approx([v[0] for v in param_history])
+            assert lrs == pytest.approx([v for i, v in lr_values])
+
+            if save_history:
+                param_history = trainer.state.param_history['lr']
+                assert lrs == pytest.approx([v[0] for v in param_history])
+
+            scheduler.load_state_dict(state_dict)
 
     _test(save_history=False)
     _test(save_history=True)
 
 
+def test_create_lr_scheduler_with_warmup_with_real_model(dummy_model_factory):
+
+    model = dummy_model_factory(with_grads=False, with_frozen_layer=False)
+    init_lr = 0.01
+    optimizer = torch.optim.SGD(model.parameters(), lr=init_lr)
+    scaled_lr = 0.02
+    warmup_duration = 5
+    step_size = 2
+    gamma = 0.97
+
+    output_simulated_values = [None] * 50
+
+    create_lr_scheduler_with_warmup(
+        torch.optim.lr_scheduler.StepLR(optimizer, step_size=step_size, gamma=gamma),
+        warmup_start_value=0.0,
+        warmup_end_value=scaled_lr,
+        warmup_duration=warmup_duration,
+        output_simulated_values=output_simulated_values
+    )
+
+    assert output_simulated_values[0] == [0, 0.0]
+    assert output_simulated_values[warmup_duration - 1] == [warmup_duration - 1, scaled_lr]
+    assert output_simulated_values[warmup_duration] == [warmup_duration, init_lr]
+    v = [warmup_duration + step_size, init_lr * gamma]
+    assert output_simulated_values[warmup_duration + step_size] == v
+
+
 def test_param_group_scheduler_asserts():
 
     t1 = torch.zeros([1], requires_grad=True)
@@ -712,9 +830,9 @@ def test_param_group_scheduler_asserts():
         {"params": t2, 'lr': 0.1},
     ])
 
-    lr_scheduler1 = LinearCyclicalScheduler(optimizer.param_groups[0], "lr",
+    lr_scheduler1 = LinearCyclicalScheduler(optimizer, "lr", param_group_index=0,
                                             start_value=1.0, end_value=0.0, cycle_size=10)
-    lr_scheduler2 = LinearCyclicalScheduler(optimizer.param_groups[1], "lr",
+    lr_scheduler2 = LinearCyclicalScheduler(optimizer, "lr", param_group_index=1,
                                             start_value=1.0, end_value=0.0, cycle_size=10)
 
     with pytest.raises(ValueError):
@@ -729,6 +847,17 @@ def test_param_group_scheduler_asserts():
     with pytest.raises(ValueError):
         ParamGroupScheduler(schedulers=[lr_scheduler1, lr_scheduler2], names=['a', ])
 
+    scheduler = ParamGroupScheduler(schedulers=[lr_scheduler1, lr_scheduler2], names=['a', 'b'])
+    with pytest.raises(ValueError, match=r"Required state attribute 'schedulers' is absent in provided state_dict"):
+        scheduler.load_state_dict({'a': 1})
+
+    with pytest.raises(ValueError, match=r"Input state_dict contains 0 state_dicts of param group schedulers"):
+        scheduler.load_state_dict({'schedulers': []})
+
+    with pytest.raises(ValueError, match=r"Name of scheduler from input state dict does not "
+                                         r"correspond to required one"):
+        scheduler.load_state_dict({'schedulers': [('a', lr_scheduler1.state_dict()), ('bad_name', {})]})
+
 
 def test_param_group_scheduler():
 
@@ -737,8 +866,8 @@ def test_param_group_scheduler():
         max_epochs = 20
 
         scheduler = ParamGroupScheduler(lr_schedulers, names=["s_{}".format(i) for i in range(len(lr_schedulers))])
+        state_dict = scheduler.state_dict()
 
-        lrs = []
         trainer = Engine(lambda engine, batch: None)
 
         @trainer.on(Events.ITERATION_COMPLETED)
@@ -750,8 +879,12 @@ def test_param_group_scheduler():
         trainer.add_event_handler(Events.ITERATION_STARTED, scheduler)
 
         data = [0] * num_iterations
-        trainer.run(data, max_epochs=max_epochs)
-        assert [lr[0] for lr in lrs] == pytest.approx([lr[1] for lr in lrs])
+
+        for _ in range(2):
+            lrs = []
+            trainer.run(data, max_epochs=max_epochs)
+            assert [lr[0] for lr in lrs] == pytest.approx([lr[1] for lr in lrs])
+            scheduler.load_state_dict(state_dict)
 
     t1 = torch.zeros([1], requires_grad=True)
     t2 = torch.zeros([1], requires_grad=True)
@@ -760,34 +893,8 @@ def test_param_group_scheduler():
         {"params": t2, 'lr': 0.1},
     ])
 
-    lr_scheduler1 = LinearCyclicalScheduler(optimizer.param_groups[0], "lr",
+    lr_scheduler1 = LinearCyclicalScheduler(optimizer, "lr", param_group_index=0,
                                             start_value=1.0, end_value=0.0, cycle_size=10)
-    lr_scheduler2 = LinearCyclicalScheduler(optimizer.param_groups[1], "lr",
+    lr_scheduler2 = LinearCyclicalScheduler(optimizer, "lr", param_group_index=1,
                                             start_value=1.0, end_value=0.0, cycle_size=10)
     _test([lr_scheduler1, lr_scheduler2], optimizer)
-
-
-def test_create_lr_scheduler_with_warmup_with_real_model(dummy_model_factory):
-
-    model = dummy_model_factory(with_grads=False, with_frozen_layer=False)
-    init_lr = 0.01
-    optimizer = torch.optim.SGD(model.parameters(), lr=init_lr)
-    scaled_lr = 0.02
-    warmup_duration = 5
-    step_size = 2
-    gamma = 0.97
-
-    output_simulated_values = [None] * 50
-
-    create_lr_scheduler_with_warmup(
-        torch.optim.lr_scheduler.StepLR(optimizer, step_size=step_size, gamma=gamma),
-        warmup_start_value=0.0,
-        warmup_end_value=scaled_lr,
-        warmup_duration=warmup_duration,
-        output_simulated_values=output_simulated_values
-    )
-    assert output_simulated_values[0] == [0, 0.0]
-    assert output_simulated_values[warmup_duration - 1] == [warmup_duration - 1, scaled_lr]
-    assert output_simulated_values[warmup_duration] == [warmup_duration, init_lr]
-    v = [warmup_duration + step_size, init_lr * gamma]
-    assert output_simulated_values[warmup_duration + step_size] == v

pip install -e .
parse_log_pytest
pytest
numpy mock pytest codecov pytest-cov matplotlib pandas gym tqdm scikit-learn tensorboardX visdom polyaxon-client mlflow
apt-get update apt-get install -y gcc
3.6
pytest --no-header -rA --tb=line --color=no -p no:cacheprovider -W ignore::DeprecationWarning
alembic==1.7.7
attrs @ file:///opt/conda/conda-bld/attrs_1642510447205/work
certifi==2021.5.30
charset-normalizer==2.0.12
click==7.1.2
cloudpickle==2.2.1
codecov==2.1.13
coverage==6.2
cycler==0.11.0
databricks-cli==0.17.8
dataclasses==0.8
decorator==4.4.2
docker==5.0.3
entrypoints==0.4
Flask==1.1.4
gitdb==4.0.9
GitPython==3.1.18
greenlet==2.0.2
gunicorn==21.2.0
gym==0.26.2
gym-notices==0.0.8
hestia==0.6.0
idna==3.10
importlib-metadata @ file:///tmp/build/80754af9/importlib-metadata_1631916693255/work
importlib-resources==5.4.0
iniconfig @ file:///home/linux1/recipes/ci/iniconfig_1610983019677/work
itsdangerous==1.1.0
Jinja2==2.10.3
joblib==1.1.1
jsonpatch==1.32
jsonpointer==2.3
kiwisolver==1.3.1
Mako==1.1.6
MarkupSafe==2.0.1
marshmallow==3.0.0rc5
matplotlib==3.3.4
mlflow==1.23.1
mock==5.2.0
more-itertools @ file:///tmp/build/80754af9/more-itertools_1637733554872/work
networkx==2.5.1
numpy==1.19.5
oauthlib==3.2.2
packaging @ file:///tmp/build/80754af9/packaging_1637314298585/work
pandas==1.1.5
Pillow==8.4.0
pluggy @ file:///tmp/build/80754af9/pluggy_1615976315926/work
polyaxon-client==0.6.1
polyaxon-schemas==0.6.1
polystores==0.2.5
prometheus-client==0.17.1
prometheus_flask_exporter==0.23.2
protobuf==4.21.0
psutil==7.0.0
py @ file:///opt/conda/conda-bld/py_1644396412707/work
PyJWT==2.4.0
pyparsing @ file:///tmp/build/80754af9/pyparsing_1635766073266/work
pytest==6.2.4
pytest-cov==4.0.0
python-dateutil==2.9.0.post0
-e git+https://github.com/pytorch/ignite.git@bfe813e330e3181ba1590ad11a0aeef13763b37a#egg=pytorch_ignite
pytz==2025.2
PyYAML==6.0.1
querystring-parser==1.2.4
requests==2.27.1
requests-toolbelt==1.0.0
rhea==0.5.5
scikit-learn==0.24.2
scipy==1.5.4
six==1.17.0
smmap==5.0.0
SQLAlchemy==1.4.54
sqlparse==0.4.4
tabulate==0.8.10
tensorboardX==2.6.2.2
threadpoolctl==3.1.0
toml @ file:///tmp/build/80754af9/toml_1616166611790/work
tomli==1.2.3
torch==1.10.2
tornado==6.1
tqdm==4.64.1
typing_extensions @ file:///opt/conda/conda-bld/typing_extensions_1647553014482/work
urllib3==1.26.20
visdom==0.2.4
websocket-client==1.3.1
Werkzeug==1.0.1
zipp @ file:///tmp/build/80754af9/zipp_1633618647012/work

name: ignite
channels:
  - defaults
  - https://repo.anaconda.com/pkgs/main
  - https://repo.anaconda.com/pkgs/r
  - conda-forge
dependencies:
  - _libgcc_mutex=0.1=main
  - _openmp_mutex=5.1=1_gnu
  - attrs=21.4.0=pyhd3eb1b0_0
  - ca-certificates=2025.2.25=h06a4308_0
  - certifi=2021.5.30=py36h06a4308_0
  - importlib-metadata=4.8.1=py36h06a4308_0
  - importlib_metadata=4.8.1=hd3eb1b0_0
  - iniconfig=1.1.1=pyhd3eb1b0_0
  - ld_impl_linux-64=2.40=h12ee557_0
  - libffi=3.3=he6710b0_2
  - libgcc-ng=11.2.0=h1234567_1
  - libgomp=11.2.0=h1234567_1
  - libstdcxx-ng=11.2.0=h1234567_1
  - more-itertools=8.12.0=pyhd3eb1b0_0
  - ncurses=6.4=h6a678d5_0
  - openssl=1.1.1w=h7f8727e_0
  - packaging=21.3=pyhd3eb1b0_0
  - pip=21.2.2=py36h06a4308_0
  - pluggy=0.13.1=py36h06a4308_0
  - py=1.11.0=pyhd3eb1b0_0
  - pyparsing=3.0.4=pyhd3eb1b0_0
  - pytest=6.2.4=py36h06a4308_2
  - python=3.6.13=h12debd9_1
  - readline=8.2=h5eee18b_0
  - setuptools=58.0.4=py36h06a4308_0
  - sqlite=3.45.3=h5eee18b_0
  - tk=8.6.14=h39e8969_0
  - toml=0.10.2=pyhd3eb1b0_0
  - typing_extensions=4.1.1=pyh06a4308_0
  - wheel=0.37.1=pyhd3eb1b0_0
  - xz=5.6.4=h5eee18b_1
  - zipp=3.6.0=pyhd3eb1b0_0
  - zlib=1.2.13=h5eee18b_1
  - pip:
      - alembic==1.7.7
      - charset-normalizer==2.0.12
      - click==7.1.2
      - cloudpickle==2.2.1
      - codecov==2.1.13
      - coverage==6.2
      - cycler==0.11.0
      - databricks-cli==0.17.8
      - dataclasses==0.8
      - decorator==4.4.2
      - docker==5.0.3
      - entrypoints==0.4
      - flask==1.1.4
      - gitdb==4.0.9
      - gitpython==3.1.18
      - greenlet==2.0.2
      - gunicorn==21.2.0
      - gym==0.26.2
      - gym-notices==0.0.8
      - hestia==0.6.0
      - idna==3.10
      - importlib-resources==5.4.0
      - itsdangerous==1.1.0
      - jinja2==2.10.3
      - joblib==1.1.1
      - jsonpatch==1.32
      - jsonpointer==2.3
      - kiwisolver==1.3.1
      - mako==1.1.6
      - markupsafe==2.0.1
      - marshmallow==3.0.0rc5
      - matplotlib==3.3.4
      - mlflow==1.23.1
      - mock==5.2.0
      - networkx==2.5.1
      - numpy==1.19.5
      - oauthlib==3.2.2
      - pandas==1.1.5
      - pillow==8.4.0
      - polyaxon-client==0.6.1
      - polyaxon-schemas==0.6.1
      - polystores==0.2.5
      - prometheus-client==0.17.1
      - prometheus-flask-exporter==0.23.2
      - protobuf==4.21.0
      - psutil==7.0.0
      - pyjwt==2.4.0
      - pytest-cov==4.0.0
      - python-dateutil==2.9.0.post0
      - pytz==2025.2
      - pyyaml==6.0.1
      - querystring-parser==1.2.4
      - requests==2.27.1
      - requests-toolbelt==1.0.0
      - rhea==0.5.5
      - scikit-learn==0.24.2
      - scipy==1.5.4
      - six==1.17.0
      - smmap==5.0.0
      - sqlalchemy==1.4.54
      - sqlparse==0.4.4
      - tabulate==0.8.10
      - tensorboardx==2.6.2.2
      - threadpoolctl==3.1.0
      - tomli==1.2.3
      - torch==1.10.2
      - tornado==6.1
      - tqdm==4.64.1
      - urllib3==1.26.20
      - visdom==0.2.4
      - websocket-client==1.3.1
      - werkzeug==1.0.1
prefix: /opt/conda/envs/ignite

tests/ignite/contrib/handlers/test_param_scheduler.py::test_linear_scheduler tests/ignite/contrib/handlers/test_param_scheduler.py::test_cosine_annealing_scheduler tests/ignite/contrib/handlers/test_param_scheduler.py::test_concat_scheduler_state_dict tests/ignite/contrib/handlers/test_param_scheduler.py::test_concat_scheduler_two_schedulers tests/ignite/contrib/handlers/test_param_scheduler.py::test_concat_scheduler_two_linear tests/ignite/contrib/handlers/test_param_scheduler.py::test_concat_scheduler_3_schedulers tests/ignite/contrib/handlers/test_param_scheduler.py::test_lr_scheduler tests/ignite/contrib/handlers/test_param_scheduler.py::test_piecewiselinear tests/ignite/contrib/handlers/test_param_scheduler.py::test_create_lr_scheduler_with_warmup tests/ignite/contrib/handlers/test_param_scheduler.py::test_create_lr_scheduler_with_warmup_on_combined_scheduler tests/ignite/contrib/handlers/test_param_scheduler.py::test_param_group_scheduler_asserts tests/ignite/contrib/handlers/test_param_scheduler.py::test_param_group_scheduler
tests/ignite/contrib/handlers/test_param_scheduler.py::test_linear_scheduler_cycle_size_two tests/ignite/contrib/handlers/test_param_scheduler.py::test_concat_scheduler_asserts tests/ignite/contrib/handlers/test_param_scheduler.py::test_save_param_history tests/ignite/contrib/handlers/test_param_scheduler.py::test_lr_scheduler_asserts tests/ignite/contrib/handlers/test_param_scheduler.py::test_piecewiselinear_asserts tests/ignite/contrib/handlers/test_param_scheduler.py::test_simulate_and_plot_values tests/ignite/contrib/handlers/test_param_scheduler.py::test_create_lr_scheduler_with_warmup_with_real_model
ignite/contrib/handlers/param_scheduler.py
ignite/contrib/handlers/param_scheduler.py