Skip to content

Commit ea6e177

Browse files
committed
fixed long lines for pylint
1 parent 70d119c commit ea6e177

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

src/sagemaker/feature_store/feature_group.py

+10-2
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,13 @@ def _run_multi_process(self, data_frame: DataFrame, wait=True, timeout=None):
276276
for i in range(self.max_processes):
277277
start_index = min(i * batch_size, data_frame.shape[0])
278278
end_index = min(i * batch_size + batch_size, data_frame.shape[0])
279-
args += [(self.max_workers, self.feature_group_name, self.sagemaker_fs_runtime_client_config, data_frame[start_index:end_index], start_index, timeout)]
279+
args += [\
280+
(self.max_workers,\
281+
self.feature_group_name, \
282+
self.sagemaker_fs_runtime_client_config, \
283+
data_frame[start_index:end_index], \
284+
start_index, \
285+
timeout)]
280286

281287
def init_worker():
282288
# ignore keyboard interrupts in child processes.
@@ -291,7 +297,9 @@ def init_worker():
291297
if wait:
292298
self.wait(timeout=timeout)
293299

294-
def _run_multi_threaded(max_workers: int, feature_group_name: str, sagemaker_fs_runtime_client_config: Config, data_frame: DataFrame, row_offset=0, timeout=None) -> List[int]:
300+
def _run_multi_threaded(max_workers: int, feature_group_name: str, \
301+
sagemaker_fs_runtime_client_config: Config, data_frame: DataFrame, row_offset=0, timeout=None) \
302+
-> List[int]:
295303
"""Start the ingestion process.
296304
297305
Args:

0 commit comments

Comments
 (0)