airflow.providers.amazon.aws.operators.mwaa¶

This module contains AWS MWAA operators.

Classes¶

MwaaTriggerDagRunOperator

Trigger a Dag Run for a Dag in an Amazon MWAA environment.

Module Contents¶

class airflow.providers.amazon.aws.operators.mwaa.MwaaTriggerDagRunOperator(*, env_name, trigger_dag_id, trigger_run_id=None, logical_date=None, data_interval_start=None, data_interval_end=None, conf=None, note=None, **kwargs)[source]¶

Bases: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.mwaa.MwaaHook]

Trigger a Dag Run for a Dag in an Amazon MWAA environment.

See also

For more information on how to use this operator, take a look at the guide: Trigger a DAG run in an Amazon MWAA environment

Parameters:

env_name (str) – The MWAA environment name (templated)
trigger_dag_id (str) – The ID of the DAG to be triggered (templated)
trigger_run_id (str | None) – The Run ID. This together with trigger_dag_id are a unique key. (templated)
logical_date (str | None) – The logical date (previously called execution date). This is the time or interval covered by this DAG run, according to the DAG definition. This together with trigger_dag_id are a unique key. (templated)
data_interval_start (str | None) – The beginning of the interval the DAG run covers
data_interval_end (str | None) – The end of the interval the DAG run covers
conf (dict | None) – Additional configuration parameters. The value of this field can be set only when creating the object. (templated)
note (str | None) – Contains manually entered notes by the user about the DagRun. (templated)

aws_hook_class[source]¶

template_fields: collections.abc.Sequence[str][source]¶

template_fields_renderers[source]¶

env_name[source]¶

trigger_dag_id[source]¶

trigger_run_id = None[source]¶

logical_date = None[source]¶

data_interval_start = None[source]¶

data_interval_end = None[source]¶

conf[source]¶

note = None[source]¶

execute(context)[source]¶

Trigger a Dag Run for the Dag in the Amazon MWAA environment.

Parameters:: context (airflow.utils.context.Context) – the Context object
Returns:: dict with information about the Dag run For details of the returned dict, see botocore.client.MWAA.invoke_rest_api()
Return type:: dict