diff --git a/catalog/dags/data_refresh/distributed_reindex.py b/catalog/dags/data_refresh/distributed_reindex.py
index 5accf63ceb5..031a367df93 100644
--- a/catalog/dags/data_refresh/distributed_reindex.py
+++ b/catalog/dags/data_refresh/distributed_reindex.py
@@ -283,7 +283,7 @@ def terminate_indexer_worker(
         raise AirflowSkipException(
             "Skipping instance termination in local environment."
         )
-    return ec2_hook.conn.terminate_instances(instance_ids=[instance_id])
+    return ec2_hook.conn.terminate_instances(InstanceIds=[instance_id])
 
 
 @task(trigger_rule=TriggerRule.ALL_DONE)