Merge pull request #614 from BDonnot/master

More customization for env.reset

Author: BDonnot

.gitignore

@@ -410,6 +410,9 @@ grid2op/tests/req_38_np121
 test_make_2_envs.py
 getting_started/env_py38_grid2op110_ray110.ipynb
 getting_started/env_py38_grid2op110_ray210.ipynb
+grid2op/tests/req_chronix2grid
+grid2op/tests/venv_test_chronix2grid/
+
 
 # profiling files
 **.prof

CHANGELOG.rst

@@ -31,12 +31,31 @@ Change Log
 - [???] "asynch" multienv
 - [???] properly model interconnecting powerlines
 
+
+- TODO A number of max buses per sub
+- TODO in the runner, save multiple times the same sceanrio
+
+
 [1.10.3] - 2024-xx-yy
 -------------------------
-- TODO A number of max buses per sub
 - TODO Automatic "experimental_read_from_local_dir"
 - TODO Notebook for stable baselines
-- TODO in the reset options: datetime start and max number of steps
+
+- [BREAKING] `env.chronics_hander.set_max_iter(xxx)` is now a private function. Use 
+  `env.set_max_iter(xxx)` or even better `env.reset(options={"max step": xxx})`. 
+  Indeed, `env.chronics_hander.set_max_iter()` will likely have
+  no effect at all on your environment.
+- [BREAKING] for all the `Handler` (*eg* `CSVForecastHandler`) the method `set_max_iter` is 
+  now private (for the same reason as the `env.chronics_handler`). We do not recommend to
+  use it (will likely have no effect). Prefer using `env.set_max_iter` instead.
+- [BREAKING] now the `runner.run()` method only accept kwargs argument 
+  (because  it should always have been like this)
+- [FIXED] a bug in the `MultiFolder` and `MultifolderWithCache` leading to the wrong 
+  computation of `max_iter` on some corner cases
+- [ADDED] possibility to skip some step when calling `env.reset(..., options={"init ts": ...})`
+- [ADDED] possibility to limit the duration of an episode with `env.reset(..., options={"max step": ...})`
+- [ADDED] possibility to specify the "reset_options" used in `env.reset` when
+  using the runner with `runner.run(..., reset_options=xxx)`
 
 [1.10.2] - 2024-05-27
 -------------------------

docs/conf.py

@@ -22,7 +22,7 @@
 author = 'Benjamin Donnot'
 
 # The full version, including alpha/beta/rc tags
-release = '1.10.3.dev0'
+release = '1.10.3.dev1'
 version = '1.10'
 
 

examples/backend_integration/Step5_modify_topology.py

@@ -207,8 +207,8 @@ def get_topo_vect(self) -> np.ndarray:
         local_topo = (1, 2, 1, 2, 1, 2)
     elif env_name == "l2rpn_wcci_2022_dev":
         raise RuntimeError("Storage units are not handled by the example backend, and there are some on the grid.")
-        sub_id = 3
-        local_topo = (1, 2, 1, 2, 1)
+        # sub_id = 3
+        # local_topo = (1, 2, 1, 2, 1)
     else:
         raise RuntimeError(f"Unknown grid2op environment name {env_name}")
     action = env.action_space({"set_bus": {"substations_id": [(sub_id, local_topo)]}})

grid2op/Chronics/chronicsHandler.py

@@ -160,13 +160,21 @@ def get_name(self):
         """
         return str(os.path.split(self.get_id())[-1])
 
-    def set_max_iter(self, max_iter: int):
+    def _set_max_iter(self, max_iter: int):
         """
         This function is used to set the maximum number of 
         iterations possible before the chronics ends.
         
         You can reset this by setting it to `-1`.
 
+        .. danger::
+            As for grid2op 1.10.3, due to the fix of a bug when
+            max_iter and fast_forward were used at the same time
+            you should not use this function anymore.
+            
+            Please use `env.set_max_iter()` instead of
+            `env.chronics_hander.set_max_iter()`
+            
         Parameters
         ----------
         max_iter: ``int``
@@ -175,9 +183,9 @@ def set_max_iter(self, max_iter: int):
 
         """
 
-        if not isinstance(max_iter, int):
+        if not isinstance(max_iter, (int, dt_int, np.int64)):
             raise Grid2OpException(
-                "The maximum number of iterations possible for this chronics, before it ends."
+                "The maximum number of iterations possible for this time series, before it ends should be an int"
             )
         if max_iter == 0:
             raise Grid2OpException(

grid2op/Chronics/handlers/baseHandler.py

@@ -73,7 +73,7 @@ def __init__(self, array_name, max_iter=-1, h_forecast=(5, )):
         self.path : Optional[os.PathLike] = None
         self.max_episode_duration : Optional[int] = None
 
-    def set_max_iter(self, max_iter: Optional[int]) -> None:
+    def _set_max_iter(self, max_iter: Optional[int]) -> None:
         """
         INTERNAL
 

grid2op/Chronics/handlers/csvForecastHandler.py

@@ -93,8 +93,8 @@ def load_next(self, dict_):
     def set_chunk_size(self, chunk_size):
         super().set_chunk_size(self._nb_row_per_step * int(chunk_size))
 
-    def set_max_iter(self, max_iter):
-        super().set_max_iter(self._nb_row_per_step * int(max_iter))
+    def _set_max_iter(self, max_iter):
+        super()._set_max_iter(self._nb_row_per_step * int(max_iter))
 
     def set_h_forecast(self, h_forecast):
         super().set_h_forecast(h_forecast)

grid2op/Chronics/multiFolder.py

@@ -441,6 +441,7 @@ def initialize(
         )
         if self.action_space is not None:
             self.data.action_space = self.action_space
+        self._max_iter = self.data.max_iter
 
     def done(self):
         """

grid2op/Chronics/multifolderWithCache.py

@@ -70,7 +70,7 @@ class MultifolderWithCache(Multifolder):
         env = make(...,chronics_class=MultifolderWithCache)
 
         # set the chronics to limit to one week of data (lower memory footprint)
-        env.chronics_handler.set_max_iter(7*288)
+        env.set_max_iter(7*288)
         # assign a filter, use only chronics that have "december" in their name
         env.chronics_handler.real_data.set_filter(lambda x: re.match(".*december.*", x) is not None)
         # create the cache
@@ -239,6 +239,7 @@ def initialize(
         id_scenario = self._order[self._prev_cache_id]
         self.data = self._cached_data[id_scenario]
         self.data.next_chronics()
+        self._max_iter = self.data.max_iter
 
     @property
     def max_iter(self):

grid2op/Chronics/time_series_from_handlers.py

@@ -204,7 +204,7 @@ def __init__(
             self.set_chunk_size(chunk_size)
 
         if max_iter != -1:
-            self.set_max_iter(max_iter)
+            self._set_max_iter(max_iter)
 
         self.init_datetime()
         self.current_inj = None
@@ -389,10 +389,10 @@ def set_chunk_size(self, new_chunk_size):
         for el in self._active_handlers:
             el.set_chunk_size(new_chunk_size)
 
-    def set_max_iter(self, max_iter):
+    def _set_max_iter(self, max_iter):
         self.max_iter = int(max_iter)
         for el in self._active_handlers:
-            el.set_max_iter(max_iter)
+            el._set_max_iter(max_iter)
 
     def init_datetime(self):
         for handl in self._active_handlers: