Configuring an RL Agent

Configuring an RL Agent#

In the previous tutorial, we saw how to train an RL agent to solve the cartpole balancing task using the Stable-Baselines3 library. In this tutorial, we will see how to configure the training process to use different RL libraries and different training algorithms.

In the directory scripts/reinforcement_learning, you will find the scripts for different RL libraries. These are organized into subdirectories named after the library name. Each subdirectory contains the training and playing scripts for the library.

To configure a learning library with a specific task, you need to create a configuration file for the learning agent. This configuration file is used to create an instance of the learning agent and is used to configure the training process. Similar to the environment registration shown in the Registering an Environment tutorial, you can register the learning agent with the gymnasium.register method.

The Code#

As an example, we will look at the configuration included for the task Isaac-Cartpole-v0 in the isaaclab_tasks package. This is the same task that we used in the Training with an RL Agent tutorial.

gym.register(
    id="Isaac-Cartpole-v0",
    entry_point="isaaclab.envs:ManagerBasedRLEnv",
    disable_env_checker=True,
    kwargs={
        "env_cfg_entry_point": f"{__name__}.cartpole_env_cfg:CartpoleEnvCfg",
        "rl_games_cfg_entry_point": f"{agents.__name__}:rl_games_ppo_cfg.yaml",
        "rsl_rl_cfg_entry_point": f"{agents.__name__}.rsl_rl_ppo_cfg:CartpolePPORunnerCfg",
        "rsl_rl_with_symmetry_cfg_entry_point": f"{agents.__name__}.rsl_rl_ppo_cfg:CartpolePPORunnerWithSymmetryCfg",
        "skrl_cfg_entry_point": f"{agents.__name__}:skrl_ppo_cfg.yaml",
        "sb3_cfg_entry_point": f"{agents.__name__}:sb3_ppo_cfg.yaml",
    },

The Code Explained#

Under the attribute kwargs, we can see the configuration for the different learning libraries. The key is the name of the library and the value is the path to the configuration instance. This configuration instance can be a string, a class, or an instance of the class. For example, the value of the key "rl_games_cfg_entry_point" is a string that points to the configuration YAML file for the RL-Games library. Meanwhile, the value of the key "rsl_rl_cfg_entry_point" points to the configuration class for the RSL-RL library.

The pattern used for specifying an agent configuration class follows closely to that used for specifying the environment configuration entry point. This means that while the following are equivalent:

Specifying the configuration entry point as a string
from . import agents

gym.register(
   id="Isaac-Cartpole-v0",
   entry_point="isaaclab.envs:ManagerBasedRLEnv",
   disable_env_checker=True,
   kwargs={
      "env_cfg_entry_point": f"{__name__}.cartpole_env_cfg:CartpoleEnvCfg",
      "rsl_rl_cfg_entry_point": f"{agents.__name__}.rsl_rl_ppo_cfg:CartpolePPORunnerCfg",
   },
)
Specifying the configuration entry point as a class
from . import agents

gym.register(
   id="Isaac-Cartpole-v0",
   entry_point="isaaclab.envs:ManagerBasedRLEnv",
   disable_env_checker=True,
   kwargs={
      "env_cfg_entry_point": f"{__name__}.cartpole_env_cfg:CartpoleEnvCfg",
      "rsl_rl_cfg_entry_point": agents.rsl_rl_ppo_cfg.CartpolePPORunnerCfg,
   },
)

The first code block is the preferred way to specify the configuration entry point. The second code block is equivalent to the first one, but it leads to import of the configuration class which slows down the import time. This is why we recommend using strings for the configuration entry point.

All the scripts in the scripts/reinforcement_learning directory are configured by default to read the <library_name>_cfg_entry_point from the kwargs dictionary to retrieve the configuration instance.

For instance, the following code block shows how the train.py script reads the configuration instance for the Stable-Baselines3 library:

Code for train.py with SB3
  1# Copyright (c) 2022-2026, The Isaac Lab Project Developers (https://github.com/isaac-sim/IsaacLab/blob/main/CONTRIBUTORS.md).
  2# All rights reserved.
  3#
  4# SPDX-License-Identifier: BSD-3-Clause
  5
  6
  7"""Script to train RL agent with Stable Baselines3."""
  8
  9import warnings
 10
 11warnings.warn(
 12    "scripts/reinforcement_learning/sb3/train.py is deprecated. Use "
 13    "`./isaaclab.sh train --rl_library sb3 --task <TASK>` instead. "
 14    "Example: `./isaaclab.sh train --rl_library sb3 --task Isaac-Cartpole-v0`.",
 15    DeprecationWarning,
 16    stacklevel=1,
 17)
 18
 19import argparse
 20import contextlib
 21import logging
 22import os
 23import random
 24import signal
 25import sys
 26import time
 27from datetime import datetime
 28from pathlib import Path
 29
 30import gymnasium as gym
 31import numpy as np
 32from stable_baselines3 import PPO
 33from stable_baselines3.common.callbacks import CheckpointCallback, LogEveryNTimesteps
 34from stable_baselines3.common.vec_env import VecNormalize
 35
 36from isaaclab.envs import DirectMARLEnvCfg, ManagerBasedRLEnvCfg
 37from isaaclab.utils.dict import print_dict
 38from isaaclab.utils.io import dump_yaml
 39from isaaclab.utils.seed import configure_seed
 40
 41from isaaclab_rl.sb3 import Sb3VecEnvWrapper, process_sb3_cfg
 42
 43import isaaclab_tasks  # noqa: F401
 44from isaaclab_tasks.utils import (
 45    add_launcher_args,
 46    fold_preset_tokens,
 47    launch_simulation,
 48    resolve_task_config,
 49    setup_preset_cli,
 50)
 51
 52logger = logging.getLogger(__name__)
 53
 54# PLACEHOLDER: Extension template (do not remove this comment)
 55with contextlib.suppress(ImportError):
 56    import isaaclab_tasks_experimental  # noqa: F401
 57
 58# -- argparse ----------------------------------------------------------------
 59parser = argparse.ArgumentParser(description="Train an RL agent with Stable-Baselines3.")
 60parser.add_argument("--video", action="store_true", default=False, help="Record videos during training.")
 61parser.add_argument("--video_length", type=int, default=200, help="Length of the recorded video (in steps).")
 62parser.add_argument("--video_interval", type=int, default=2000, help="Interval between video recordings (in steps).")
 63parser.add_argument("--num_envs", type=int, default=None, help="Number of environments to simulate.")
 64parser.add_argument("--task", type=str, default=None, help="Name of the task.")
 65parser.add_argument(
 66    "--agent", type=str, default="sb3_cfg_entry_point", help="Name of the RL agent configuration entry point."
 67)
 68parser.add_argument("--seed", type=int, default=None, help="Seed used for the environment")
 69parser.add_argument("--log_interval", type=int, default=100_000, help="Log data every n timesteps.")
 70parser.add_argument("--checkpoint", type=str, default=None, help="Continue the training from checkpoint.")
 71parser.add_argument("--max_iterations", type=int, default=None, help="RL Policy training iterations.")
 72parser.add_argument("--export_io_descriptors", action="store_true", default=False, help="Export IO descriptors.")
 73parser.add_argument(
 74    "--keep_all_info",
 75    action="store_true",
 76    default=False,
 77    help="Use a slower SB3 wrapper but keep all the extra training info.",
 78)
 79parser.add_argument(
 80    "--ray-proc-id", "-rid", type=int, default=None, help="Automatically configured by Ray integration, otherwise None."
 81)
 82add_launcher_args(parser)
 83args_cli, hydra_args = setup_preset_cli(parser)
 84sys.argv = [sys.argv[0]] + fold_preset_tokens(hydra_args)
 85
 86if args_cli.video:
 87    args_cli.enable_cameras = True
 88
 89
 90def cleanup_pbar(*args):
 91    """
 92    A small helper to stop training and
 93    cleanup progress bar properly on ctrl+c
 94    """
 95    import gc
 96
 97    tqdm_objects = [obj for obj in gc.get_objects() if "tqdm" in type(obj).__name__]
 98    for tqdm_object in tqdm_objects:
 99        if "tqdm_rich" in type(tqdm_object).__name__:
100            tqdm_object.close()
101    raise KeyboardInterrupt
102
103
104signal.signal(signal.SIGINT, cleanup_pbar)
105
106
107def main():
108    """Train with stable-baselines agent."""
109    env_cfg, agent_cfg = resolve_task_config(args_cli.task, args_cli.agent)
110    with launch_simulation(env_cfg, args_cli):
111        # randomly sample a seed if seed = -1
112        if args_cli.seed == -1:
113            args_cli.seed = random.randint(0, 10000)
114
115        # override configurations with non-hydra CLI arguments
116        env_cfg.scene.num_envs = args_cli.num_envs if args_cli.num_envs is not None else env_cfg.scene.num_envs
117        agent_cfg["seed"] = args_cli.seed if args_cli.seed is not None else agent_cfg["seed"]
118        # max iterations for training
119        if args_cli.max_iterations is not None:
120            agent_cfg["n_timesteps"] = args_cli.max_iterations * agent_cfg["n_steps"] * env_cfg.scene.num_envs
121
122        # set the environment seed
123        env_cfg.seed = agent_cfg["seed"]
124        env_cfg.sim.device = args_cli.device if args_cli.device is not None else env_cfg.sim.device
125
126        # directory for logging into
127        run_info = datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
128        log_root_path = os.path.abspath(os.path.join("logs", "sb3", args_cli.task))
129        print(f"[INFO] Logging experiment in directory: {log_root_path}")
130        print(f"Exact experiment name requested from command line: {run_info}")
131        log_dir = os.path.join(log_root_path, run_info)
132        # dump the configuration into log-directory
133        dump_yaml(os.path.join(log_dir, "params", "env.yaml"), env_cfg)
134        dump_yaml(os.path.join(log_dir, "params", "agent.yaml"), agent_cfg)
135
136        # save command used to run the script
137        command = " ".join(sys.orig_argv)
138        (Path(log_dir) / "command.txt").write_text(command)
139
140        # post-process agent configuration
141        agent_cfg = process_sb3_cfg(agent_cfg, env_cfg.scene.num_envs)
142        # read configurations about the agent-training
143        policy_arch = agent_cfg.pop("policy")
144        n_timesteps = agent_cfg.pop("n_timesteps")
145
146        # set the IO descriptors export flag if requested
147        if isinstance(env_cfg, ManagerBasedRLEnvCfg):
148            env_cfg.export_io_descriptors = args_cli.export_io_descriptors
149        else:
150            logger.warning(
151                "IO descriptors are only supported for manager based RL environments."
152                " No IO descriptors will be exported."
153            )
154
155        # set the log directory for the environment
156        env_cfg.log_dir = log_dir
157
158        # create isaac environment
159        env = gym.make(args_cli.task, cfg=env_cfg, render_mode="rgb_array" if args_cli.video else None)
160
161        # convert to single-agent instance if required by the RL algorithm
162        if isinstance(env.unwrapped.cfg, DirectMARLEnvCfg):
163            from isaaclab.envs import multi_agent_to_single_agent
164
165            env = multi_agent_to_single_agent(env)
166
167        # wrap for video recording
168        if args_cli.video:
169            video_kwargs = {
170                "video_folder": os.path.join(log_dir, "videos", "train"),
171                "step_trigger": lambda step: step % args_cli.video_interval == 0,
172                "video_length": args_cli.video_length,
173                "disable_logger": True,
174            }
175            print("[INFO] Recording videos during training.")
176            print_dict(video_kwargs, nesting=4)
177            env = gym.wrappers.RecordVideo(env, **video_kwargs)
178
179        start_time = time.time()
180
181        # wrap around environment for stable baselines
182        env = Sb3VecEnvWrapper(env, fast_variant=not args_cli.keep_all_info)
183
184        norm_keys = {"normalize_input", "normalize_value", "clip_obs"}
185        norm_args = {}
186        for key in norm_keys:
187            if key in agent_cfg:
188                norm_args[key] = agent_cfg.pop(key)
189
190        if norm_args and norm_args.get("normalize_input"):
191            print(f"Normalizing input, {norm_args=}")
192            env = VecNormalize(
193                env,
194                training=True,
195                norm_obs=norm_args["normalize_input"],
196                norm_reward=norm_args.get("normalize_value", False),
197                clip_obs=norm_args.get("clip_obs", 100.0),
198                gamma=agent_cfg["gamma"],
199                clip_reward=np.inf,
200            )
201
202        # create agent from stable baselines
203        agent = PPO(policy_arch, env, verbose=1, tensorboard_log=log_dir, **agent_cfg)
204        if args_cli.checkpoint is not None:
205            agent = agent.load(args_cli.checkpoint, env, print_system_info=True)
206        # configure_seed must be called after PPO construction (and optional load) so that PyTorch
207        # deterministic settings do not interfere with SB3's internal initialization.
208        if args_cli.deterministic:
209            configure_seed(env_cfg.seed, True)
210
211        # callbacks for agent
212        checkpoint_callback = CheckpointCallback(save_freq=1000, save_path=log_dir, name_prefix="model", verbose=2)
213        callbacks = [checkpoint_callback, LogEveryNTimesteps(n_steps=args_cli.log_interval)]
214
215        # train the agent
216        with contextlib.suppress(KeyboardInterrupt):
217            agent.learn(
218                total_timesteps=n_timesteps,
219                callback=callbacks,
220                progress_bar=True,
221                log_interval=None,
222            )
223        # save the final model
224        agent.save(os.path.join(log_dir, "model"))
225        print("Saving to:")
226        print(os.path.join(log_dir, "model.zip"))
227
228        if isinstance(env, VecNormalize):
229            print("Saving normalization")
230            env.save(os.path.join(log_dir, "model_vecnormalize.pkl"))
231
232        print(f"Training time: {round(time.time() - start_time, 2)} seconds")
233
234        # close the simulator
235        env.close()
236
237
238if __name__ == "__main__":
239    main()

The argument --agent is used to specify the learning library to use. This is used to retrieve the configuration instance from the kwargs dictionary. You can manually specify alternate configuration instances by passing the --agent argument.

The Code Execution#

Since for the cartpole balancing task, RSL-RL library offers two configuration instances, we can use the --agent argument to specify the configuration instance to use.

  • Training with the standard PPO configuration:

    # standard PPO training
    ./isaaclab.sh -p scripts/reinforcement_learning/rsl_rl/train.py --task Isaac-Cartpole-v0 --headless \
      --run_name ppo
    
  • Training with the PPO configuration with symmetry augmentation:

    # PPO training with symmetry augmentation
    ./isaaclab.sh -p scripts/reinforcement_learning/rsl_rl/train.py --task Isaac-Cartpole-v0 --headless \
      --agent rsl_rl_with_symmetry_cfg_entry_point \
      --run_name ppo_with_symmetry_data_augmentation
    
    # you can use hydra to disable symmetry augmentation but enable mirror loss computation
    ./isaaclab.sh -p scripts/reinforcement_learning/rsl_rl/train.py --task Isaac-Cartpole-v0 --headless \
      --agent rsl_rl_with_symmetry_cfg_entry_point \
      --run_name ppo_without_symmetry_data_augmentation \
      agent.algorithm.symmetry_cfg.use_data_augmentation=false
    

The --run_name argument is used to specify the name of the run. This is used to create a directory for the run in the logs/rsl_rl/cartpole directory.