File tree Expand file tree Collapse file tree 1 file changed +15
-1
lines changed
ads/jobs/builders/infrastructure Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Original file line number Diff line number Diff line change @@ -1601,6 +1601,18 @@ def _update_job_infra(self, dsc_job: DSCJob) -> DataScienceJob:
1601
1601
if value :
1602
1602
dsc_job .job_infrastructure_configuration_details [camel_attr ] = value
1603
1603
1604
+ shape = dsc_job .job_infrastructure_configuration_details .get ("shapeName" , "" )
1605
+ if (
1606
+ shape
1607
+ and not str (shape ).endswith ("Flex" )
1608
+ and dsc_job .job_infrastructure_configuration_details .get (
1609
+ "jobShapeConfigDetails"
1610
+ )
1611
+ ):
1612
+ raise ValueError (
1613
+ "Shape config is not required for non flex shape from user end."
1614
+ )
1615
+
1604
1616
if dsc_job .job_infrastructure_configuration_details .get ("subnetId" ):
1605
1617
dsc_job .job_infrastructure_configuration_details [
1606
1618
"jobInfrastructureType"
@@ -1648,7 +1660,9 @@ def init(self, **kwargs) -> DataScienceJob:
1648
1660
def _config_multi_node (self , runtime : MultiNodeRuntime ):
1649
1661
"""Configure the payload for multi-node job run."""
1650
1662
infra_config : dict = self .dsc_job .job_infrastructure_configuration_details
1651
- job_config : models .DefaultJobConfigurationDetails = self .dsc_job .job_configuration_details
1663
+ job_config : models .DefaultJobConfigurationDetails = (
1664
+ self .dsc_job .job_configuration_details
1665
+ )
1652
1666
env_config = self .dsc_job .job_environment_configuration_details
1653
1667
# For multi-node jobs,
1654
1668
# the job_infrastructure_configuration_details and job_configuration_details
You can’t perform that action at this time.
0 commit comments