syedahsn commented on code in PR #32563:
URL: https://github.com/apache/airflow/pull/32563#discussion_r1268745943
##
airflow/providers/amazon/aws/operators/step_function.py:
##
@@ -74,9 +88,25 @@ def execute(self, context: Context):
raise AirflowException(f"Failed t
syedahsn commented on code in PR #32563:
URL: https://github.com/apache/airflow/pull/32563#discussion_r1265972454
##
airflow/providers/amazon/aws/waiters/stepfunctions.json:
##
@@ -0,0 +1,36 @@
+{
+"version": 2,
+"waiters": {
+"step_function_succeeded": {
+
syedahsn commented on code in PR #32563:
URL: https://github.com/apache/airflow/pull/32563#discussion_r1265957022
##
airflow/providers/amazon/aws/operators/step_function.py:
##
@@ -74,9 +88,25 @@ def execute(self, context: Context):
raise AirflowException(f"Failed t
syedahsn commented on code in PR #32563:
URL: https://github.com/apache/airflow/pull/32563#discussion_r1265947168
##
airflow/providers/amazon/aws/operators/step_function.py:
##
@@ -74,9 +88,25 @@ def execute(self, context: Context):
raise AirflowException(f"Failed t
syedahsn commented on code in PR #32563:
URL: https://github.com/apache/airflow/pull/32563#discussion_r1265945119
##
airflow/providers/amazon/aws/operators/step_function.py:
##
@@ -42,6 +45,11 @@ class StepFunctionStartExecutionOperator(BaseOperator):
:param state_machine_i
syedahsn commented on code in PR #32563:
URL: https://github.com/apache/airflow/pull/32563#discussion_r1262918852
##
airflow/providers/amazon/aws/operators/step_function.py:
##
@@ -74,9 +88,25 @@ def execute(self, context: Context):
raise AirflowException(f"Failed t
