feast-dev
diff --git a/‎sdk/python/feast/pyspark/launchers/aws/emr_utils.py‎
Lines changed: 1 addition & 1 deletion b/‎sdk/python/feast/pyspark/launchers/aws/emr_utils.py‎
Lines changed: 1 addition & 1 deletion
@@ -290,7 +290,7 @@ def _cancel_job(emr_client, job: EmrJobRef):
     emr_client.cancel_steps(
         ClusterId=job.cluster_id,
         StepIds=[step_id],
-        StepCancellationOption="TERMINATE_PROCESS",
+        StepCancellationOption="SEND_INTERRUPT",
     )
 
     _wait_for_job_state(
Original file line number	Diff line number	Diff line change
`@@ -290,7 +290,7 @@ def _cancel_job(emr_client, job: EmrJobRef):`
`290`	`290`	`emr_client.cancel_steps(`
`291`	`291`	`ClusterId=job.cluster_id,`
`292`	`292`	`StepIds=[step_id],`
`293`		`- StepCancellationOption="TERMINATE_PROCESS",`
	`293`	`+ StepCancellationOption="SEND_INTERRUPT",`
`294`	`294`	`)`
`295`	`295`
`296`	`296`	`_wait_for_job_state(`