Lock file maintenance; backcompat fix for experimental/beta decorators (#81)

* Lock file maintenance

* backcompat fix for experimenta/beta decorators

---------

Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>
Co-authored-by: danielgafni <danielgafni16@gmail.com>

Author: renovate[bot]

.github/workflows/CI.yml

@@ -39,7 +39,7 @@ jobs:
           - "2.37.0"
           - "2.24.0"
         dagster:
-          - "1.10.1"
+          - "1.10.2"
         kuberay:
           - "1.3.0-rc.1"
           - "1.2.2"

dagster_ray/kuberay/pipes.py

@@ -6,7 +6,7 @@
 import dagster._check as check
 import yaml
 from dagster import AssetExecutionContext, DagsterInvariantViolationError, OpExecutionContext, PipesClient
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from dagster._core.definitions.resource_annotation import TreatAsResourceParam
 from dagster._core.errors import DagsterExecutionInterruptedError
 from dagster._core.pipes.client import (
@@ -30,7 +30,7 @@
 OpOrAssetExecutionContext: TypeAlias = Union[OpExecutionContext, AssetExecutionContext]
 
 
-@experimental
+@beta
 class PipesKubeRayJobClient(PipesClient, TreatAsResourceParam):
     """A pipes client for running ``RayJob`` on Kubernetes.
 

dagster_ray/kuberay/resources.py

@@ -11,7 +11,7 @@
 
 import dagster._check as check
 from dagster import ConfigurableResource, InitResourceContext
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from pydantic import Field, PrivateAttr
 
 from dagster_ray._base.constants import DEFAULT_DEPLOYMENT_NAME
@@ -36,7 +36,7 @@
     import kubernetes
 
 
-@experimental
+@beta
 class RayClusterClientResource(ConfigurableResource):
     kube_context: str | None = None
     kubeconfig_file: str | None = None
@@ -73,7 +73,7 @@ def setup_for_execution(self, context: InitResourceContext) -> None:
         self._k8s_core_api = kubernetes.client.CoreV1Api()
 
 
-@experimental
+@beta
 class KubeRayCluster(BaseRayResource):
     """
     Provides a RayCluster for the current step selection

dagster_ray/pipes.py

@@ -10,7 +10,7 @@
 
 import dagster._check as check
 from dagster import AssetExecutionContext, OpExecutionContext, PipesClient
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from dagster._core.definitions.resource_annotation import TreatAsResourceParam
 from dagster._core.errors import DagsterExecutionInterruptedError
 from dagster._core.pipes.client import (
@@ -37,7 +37,7 @@
 OpOrAssetExecutionContext: TypeAlias = Union[OpExecutionContext, AssetExecutionContext]
 
 
-@experimental
+@beta
 class PipesRayJobMessageReader(PipesMessageReader):
     """
     Dagster Pipes message reader for receiving messages from a Ray job.
@@ -164,7 +164,7 @@ def generate_job_id() -> str:
     return f"pipes-{random_letters}"
 
 
-@experimental
+@beta
 class PipesRayJobClient(PipesClient, TreatAsResourceParam):
     """A pipes client for running Ray jobs on remote clusters.