hanzo-ml/trainer
1
0
Fork 0
mirror of https://github.com/hanzo-ml/trainer.git synced 2026-09-24 00:31:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(operator): Upgrade JobSet to v0.10.1 (#2875)

Browse Source 
Signed-off-by: Antonin Stefanutti <[email protected]>
This commit is contained in:
Antonin Stefanutti
2025-10-03 10:08:08 +00:00
committed by GitHub
parent 6e5b6e6768
commit afb208d86e
12 changed files with 152 additions and 70 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/python_api/kubeflow_trainer_api/models/jobset_v1alpha2_failure_policy_rule.py
Generated
+5 -3
View File
@@ -24,13 +24,14 @@ from typing_extensions import Self
class JobsetV1alpha2FailurePolicyRule(BaseModel):
"""
FailurePolicyRule defines a FailurePolicyAction to be executed if a child job fails due to a reason listed in OnJobFailureReasons.
FailurePolicyRule defines a FailurePolicyAction to be executed if a child job fails due to a reason listed in OnJobFailureReasons and a message pattern listed in OnJobFailureMessagePatterns. The rule must match both the job failure reason and the job failure message. The rules are evaluated in order and the first matching rule is executed.
""" # noqa: E501
action: StrictStr = Field(description="The action to take if the rule is matched.")
name: StrictStr = Field(description="The name of the failure policy rule. The name is defaulted to 'failurePolicyRuleN' where N is the index of the failure policy rule. The name must match the regular expression \"^[A-Za-z]([A-Za-z0-9_,:]*[A-Za-z0-9_])?$\".")
on_job_failure_reasons: Optional[List[StrictStr]] = Field(default=None, description="The requirement on the job failure reasons. The requirement is satisfied if at least one reason matches the list. The rules are evaluated in order, and the first matching rule is executed. An empty list applies the rule to any job failure reason.", alias="onJobFailureReasons")
on_job_failure_message_patterns: Optional[List[StrictStr]] = Field(default=None, description="The requirement on the job failure message. The requirement is satisfied if at least one pattern (regex) matches the job failure message. An empty list matches any job failure message. The syntax of the regular expressions accepted is the same general syntax used by Perl, Python, and other languages. More precisely, it is the syntax accepted by RE2 and described at https://golang.org/s/re2syntax, except for \\C. For an overview of the syntax, see https://pkg.go.dev/regexp/syntax.", alias="onJobFailureMessagePatterns")
on_job_failure_reasons: Optional[List[StrictStr]] = Field(default=None, description="The requirement on the job failure reasons. The requirement is satisfied if at least one reason matches the list. An empty list matches any job failure reason.", alias="onJobFailureReasons")
target_replicated_jobs: Optional[List[StrictStr]] = Field(default=None, description="TargetReplicatedJobs are the names of the replicated jobs the operator applies to. An empty list will apply to all replicatedJobs.", alias="targetReplicatedJobs")
__properties: ClassVar[List[str]] = ["action", "name", "onJobFailureReasons", "targetReplicatedJobs"]
__properties: ClassVar[List[str]] = ["action", "name", "onJobFailureMessagePatterns", "onJobFailureReasons", "targetReplicatedJobs"]
model_config = ConfigDict(
populate_by_name=True,
@@ -85,6 +86,7 @@ class JobsetV1alpha2FailurePolicyRule(BaseModel):
_obj = cls.model_validate({
"action": obj.get("action") if obj.get("action") is not None else '',
"name": obj.get("name") if obj.get("name") is not None else '',
"onJobFailureMessagePatterns": obj.get("onJobFailureMessagePatterns"),
"onJobFailureReasons": obj.get("onJobFailureReasons"),
"targetReplicatedJobs": obj.get("targetReplicatedJobs")
})