Skip to content

Commit cc9cf32

Browse files
committed
Fixed pylint
1 parent 54b7200 commit cc9cf32

File tree

2 files changed

+10
-5
lines changed

2 files changed

+10
-5
lines changed

src/sagemaker/estimator.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2607,9 +2607,8 @@ def _distribution_configuration(self, distribution):
26072607
distribution_config[self.LAUNCH_SM_DDP_ENV_NAME] = smdataparallel_enabled
26082608
distribution_config[self.INSTANCE_TYPE] = self.instance_type
26092609
if smdataparallel_enabled:
2610-
distribution_config[self.SM_DDP_CUSTOM_MPI_OPTIONS] = smdistributed["dataparallel"].get(
2611-
"custom_mpi_options", ""
2612-
)
2610+
distribution_config[self.SM_DDP_CUSTOM_MPI_OPTIONS] = \
2611+
smdistributed["dataparallel"].get("custom_mpi_options", "")
26132612

26142613
return distribution_config
26152614

tests/unit/test_estimator.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,8 +120,14 @@
120120
DISTRIBUTION_MPI_ENABLED = {
121121
"mpi": {"enabled": True, "custom_mpi_options": "options", "processes_per_host": 2}
122122
}
123-
DISTRIBUTION_SM_DDP_ENABLED = {"smdistributed": {"dataparallel": {"enabled": True,
124-
"custom_mpi_options": "options"}}}
123+
DISTRIBUTION_SM_DDP_ENABLED = {
124+
"smdistributed": {
125+
"dataparallel": {
126+
"enabled": True,
127+
"custom_mpi_options": "options"
128+
}
129+
}
130+
}
125131

126132

127133
class DummyFramework(Framework):

0 commit comments

Comments
 (0)