This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new eed1a39135b Rename StepFunctionStartExecutionOperator's input field to
match its constructor argument (#70544)
eed1a39135b is described below
commit eed1a39135b6c285c11b9a44d19622952ac8952c
Author: Bramhanand Lingala <[email protected]>
AuthorDate: Wed Jul 29 18:51:10 2026 +0530
Rename StepFunctionStartExecutionOperator's input field to match its
constructor argument (#70544)
---
.../src/airflow/providers/amazon/aws/operators/step_function.py | 6 +++---
.../amazon/tests/unit/amazon/aws/operators/test_step_function.py | 2 +-
scripts/ci/prek/validate_operators_init_exemptions.txt | 1 -
3 files changed, 4 insertions(+), 5 deletions(-)
diff --git
a/providers/amazon/src/airflow/providers/amazon/aws/operators/step_function.py
b/providers/amazon/src/airflow/providers/amazon/aws/operators/step_function.py
index 7c5c6a31cb9..4ae43673290 100644
---
a/providers/amazon/src/airflow/providers/amazon/aws/operators/step_function.py
+++
b/providers/amazon/src/airflow/providers/amazon/aws/operators/step_function.py
@@ -76,7 +76,7 @@ class
StepFunctionStartExecutionOperator(AwsBaseOperator[StepFunctionHook]):
aws_hook_class = StepFunctionHook
template_fields: Sequence[str] = aws_template_fields(
- "state_machine_arn", "name", "input", "is_redrive_execution"
+ "state_machine_arn", "name", "state_machine_input",
"is_redrive_execution"
)
ui_color = "#f9c915"
operator_extra_links = (StateMachineDetailsLink(),
StateMachineExecutionsDetailsLink())
@@ -97,7 +97,7 @@ class
StepFunctionStartExecutionOperator(AwsBaseOperator[StepFunctionHook]):
self.state_machine_arn = state_machine_arn
self.name = name
self.is_redrive_execution = is_redrive_execution
- self.input = state_machine_input
+ self.state_machine_input = state_machine_input
self.waiter_delay = waiter_delay
self.waiter_max_attempts = waiter_max_attempts
self.deferrable = deferrable
@@ -113,7 +113,7 @@ class
StepFunctionStartExecutionOperator(AwsBaseOperator[StepFunctionHook]):
if not (
execution_arn := self.hook.start_execution(
- self.state_machine_arn, self.name, self.input,
self.is_redrive_execution
+ self.state_machine_arn, self.name, self.state_machine_input,
self.is_redrive_execution
)
):
raise AirflowException(f"Failed to start State Machine execution
for: {self.state_machine_arn}")
diff --git
a/providers/amazon/tests/unit/amazon/aws/operators/test_step_function.py
b/providers/amazon/tests/unit/amazon/aws/operators/test_step_function.py
index 55a0913405f..9d58968a702 100644
--- a/providers/amazon/tests/unit/amazon/aws/operators/test_step_function.py
+++ b/providers/amazon/tests/unit/amazon/aws/operators/test_step_function.py
@@ -144,7 +144,7 @@ class TestStepFunctionStartExecutionOperator:
assert op.state_machine_arn == STATE_MACHINE_ARN
assert op.state_machine_arn == STATE_MACHINE_ARN
assert op.name == NAME
- assert op.input == INPUT
+ assert op.state_machine_input == INPUT
assert op.hook.aws_conn_id == AWS_CONN_ID
assert op.hook._region_name == REGION_NAME
assert op.hook._verify is False
diff --git a/scripts/ci/prek/validate_operators_init_exemptions.txt
b/scripts/ci/prek/validate_operators_init_exemptions.txt
index 76ba180595a..559ff95bdff 100644
--- a/scripts/ci/prek/validate_operators_init_exemptions.txt
+++ b/scripts/ci/prek/validate_operators_init_exemptions.txt
@@ -10,7 +10,6 @@
providers/amazon/src/airflow/providers/amazon/aws/operators/neptune.py::NeptuneS
providers/amazon/src/airflow/providers/amazon/aws/operators/s3.py::S3DeleteObjectsOperator
providers/amazon/src/airflow/providers/amazon/aws/operators/sagemaker.py::SageMakerCreateNotebookOperator
providers/amazon/src/airflow/providers/amazon/aws/operators/sagemaker.py::SageMakerProcessingOperator
-providers/amazon/src/airflow/providers/amazon/aws/operators/step_function.py::StepFunctionStartExecutionOperator
providers/amazon/src/airflow/providers/amazon/aws/transfers/gcs_to_s3.py::GCSToS3Operator
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py::KubernetesPodOperator
providers/google/src/airflow/providers/google/cloud/operators/cloud_batch.py::CloudBatchSubmitJobOperator
