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 0924676ce5d Set `wait_for_completion` to True in example_mwaa system
test (#47877)
0924676ce5d is described below
commit 0924676ce5df16b61dde44f3f7f35cd2a498784a
Author: Ramit Kataria <[email protected]>
AuthorDate: Mon Mar 17 14:33:40 2025 -0700
Set `wait_for_completion` to True in example_mwaa system test (#47877)
This ensures the operator's waiter logic is also tested in this system
test in addition to poking in the sensor.
---
providers/amazon/docs/operators/mwaa.rst | 2 +-
providers/amazon/tests/system/amazon/aws/example_mwaa.py | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/providers/amazon/docs/operators/mwaa.rst
b/providers/amazon/docs/operators/mwaa.rst
index 7eb9bab3983..20108743f2b 100644
--- a/providers/amazon/docs/operators/mwaa.rst
+++ b/providers/amazon/docs/operators/mwaa.rst
@@ -49,7 +49,7 @@ To trigger a DAG run in an Amazon MWAA environment you can
use the
:class:`~airflow.providers.amazon.aws.operators.mwaa.MwaaTriggerDagRunOperator`
In the following example, the task ``trigger_dag_run`` triggers a DAG run for
the DAG ``hello_world`` in the environment
-``MyAirflowEnvironment``.
+``MyAirflowEnvironment`` and waits for the run to complete.
.. exampleinclude::
/../../providers/amazon/tests/system/amazon/aws/example_mwaa.py
:language: python
diff --git a/providers/amazon/tests/system/amazon/aws/example_mwaa.py
b/providers/amazon/tests/system/amazon/aws/example_mwaa.py
index dd76a0ed5dc..2ec11653060 100644
--- a/providers/amazon/tests/system/amazon/aws/example_mwaa.py
+++ b/providers/amazon/tests/system/amazon/aws/example_mwaa.py
@@ -72,6 +72,7 @@ with DAG(
task_id="trigger_dag_run",
env_name=env_name,
trigger_dag_id=trigger_dag_id,
+ wait_for_completion=True,
)
# [END howto_operator_mwaa_trigger_dag_run]
