airflow.providers.amazon.aws.operators.dms_describe_tasks

Module Contents

class airflow.providers.amazon.aws.operators.dms_describe_tasks.DmsDescribeTasksOperator(*, describe_tasks_kwargs: Optional[dict] = None, aws_conn_id: str = 'aws_default', **kwargs)[source]

Bases: airflow.models.BaseOperator

Describes AWS DMS replication tasks.

Parameters

  • describe_tasks_kwargs (Optional[dict]) -- Describe tasks command arguments

  • aws_conn_id (Optional[str]) -- The Airflow connection used for AWS credentials. If this is None or empty then the default boto3 behaviour is used. If running Airflow in a distributed manner and aws_conn_id is None or empty, then default boto3 configuration would be used (and must be maintained on each worker node).

template_fields = ['describe_tasks_kwargs'][source]
template_ext = [][source]
template_fields_renderers[source]
execute(self, context)[source]

Describes AWS DMS replication tasks from Airflow

Returns

Marker and list of replication tasks

Return type

(Optional[str], list)

Was this entry helpful?