Skip to content

Commit 2f30e85

Browse files
committed
reset command for each run invocation
1 parent 7d1916d commit 2f30e85

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/sagemaker/spark/processing.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -737,7 +737,8 @@ def run(
737737
user code file (default: None).
738738
"""
739739
self._current_job_name = self._generate_current_job_name(job_name=job_name)
740-
740+
self.command = [_SparkProcessorBase._default_command]
741+
741742
if not submit_app:
742743
raise ValueError("submit_app is required")
743744

@@ -917,6 +918,7 @@ def run(
917918
user code file (default: None).
918919
"""
919920
self._current_job_name = self._generate_current_job_name(job_name=job_name)
921+
self.command = [_SparkProcessorBase._default_command]
920922

921923
if not submit_app:
922924
raise ValueError("submit_app is required")

0 commit comments

Comments
 (0)