diff --git a/dagster_ray/kuberay/pipes.py b/dagster_ray/kuberay/pipes.py index ea2ecf3..4a1190a 100644 --- a/dagster_ray/kuberay/pipes.py +++ b/dagster_ray/kuberay/pipes.py @@ -68,7 +68,7 @@ def __init__( @property def job_submission_client(self) -> "JobSubmissionClient": if self._job_submission_client is None: - raise DagsterInvariantViolationError("JobSubmissionClient is not available inside the run method.") + raise DagsterInvariantViolationError("JobSubmissionClient is only available inside the run method.") else: return self._job_submission_client