diff --git a/providers/amazon/docs/operators/mwaa.rst b/providers/amazon/docs/operators/mwaa.rst index 7eb9bab3983bc..20108743f2b8b 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 dd76a0ed5dc08..2ec11653060b9 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 @@ 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]