[Train] Remove the subclass relationship between RunConfig and RunConfigV1 (#54293)

In RunConfig, it subclasses RunConfigV1, whose `__post_init__` is using
v1 configs to initialize.
Now we remove the subclass relationship to avoid unexpected bugs.


---------

Signed-off-by: xgui <[email protected]>

Author: xinyuangui2

python/ray/train/v2/api/config.py

@@ -1,9 +1,13 @@
+import logging
 from dataclasses import dataclass
+from pathlib import Path
 from typing import TYPE_CHECKING, List, Optional, Union
 
+import pyarrow.fs
+
 from ray.air.config import (
+    CheckpointConfig,
     FailureConfig as FailureConfigV1,
-    RunConfig as RunConfigV1,
     ScalingConfig as ScalingConfigV1,
 )
 from ray.runtime_env import RuntimeEnv
@@ -13,11 +17,15 @@
     TRAINER_RESOURCES_DEPRECATION_MESSAGE,
 )
 from ray.train.v2._internal.util import date_str
+from ray.util.annotations import PublicAPI
 
 if TYPE_CHECKING:
     from ray.train import UserCallback
 
 
+logger = logging.getLogger(__name__)
+
+
 @dataclass
 class ScalingConfig(ScalingConfigV1):
     """Configuration for scaling training.
@@ -97,7 +105,8 @@ def __post_init__(self):
 
 
 @dataclass
-class RunConfig(RunConfigV1):
+@PublicAPI(stability="stable")
+class RunConfig:
     """Runtime configuration for training runs.
 
     Args:
@@ -119,6 +128,11 @@ class RunConfig(RunConfigV1):
             for all Ray Train worker actors.
     """
 
+    name: Optional[str] = None
+    storage_path: Optional[str] = None
+    storage_filesystem: Optional[pyarrow.fs.FileSystem] = None
+    failure_config: Optional[FailureConfig] = None
+    checkpoint_config: Optional[CheckpointConfig] = None
     callbacks: Optional[List["UserCallback"]] = None
     worker_runtime_env: Optional[Union[dict, RuntimeEnv]] = None
 
@@ -129,7 +143,19 @@ class RunConfig(RunConfigV1):
     log_to_file: str = _DEPRECATED
 
     def __post_init__(self):
-        super().__post_init__()
+        from ray.train.constants import DEFAULT_STORAGE_PATH
+
+        if self.storage_path is None:
+            self.storage_path = DEFAULT_STORAGE_PATH
+
+        if not self.failure_config:
+            self.failure_config = FailureConfig()
+
+        if not self.checkpoint_config:
+            self.checkpoint_config = CheckpointConfig()
+
+        if isinstance(self.storage_path, Path):
+            self.storage_path = self.storage_path.as_posix()
 
         # TODO(justinvyu): Add link to migration guide.
         run_config_deprecation_message = (

python/ray/train/v2/tests/test_v2_api.py

@@ -30,6 +30,26 @@ def test_api_configs(operation, raise_error):
             pytest.fail(f"Default Operation raised an exception: {e}")
 
 
+def test_run_config_default_failure_config():
+    """Test that RunConfig creates a default FailureConfig from v2 API, not v1."""
+    # Import the v2 FailureConfig and v1 FailureConfig for comparison
+    from ray.train.v2.api.config import FailureConfig as FailureConfigV2
+
+    # Create a RunConfig without specifying failure_config
+    run_config = RunConfig()
+
+    # Verify that the default failure_config is the v2 version
+    assert run_config.failure_config is not None
+    assert isinstance(run_config.failure_config, FailureConfigV2)
+    assert type(run_config.failure_config) is FailureConfigV2
+
+    # Verify that explicitly passing None also creates v2 FailureConfig
+    run_config_explicit_none = RunConfig(failure_config=None)
+    assert run_config_explicit_none.failure_config is not None
+    assert isinstance(run_config_explicit_none.failure_config, FailureConfigV2)
+    assert type(run_config_explicit_none.failure_config) is FailureConfigV2
+
+
 def test_scaling_config_total_resources():
     """Test the patched scaling config total resources calculation."""
     num_workers = 2