`airflow.providers.amazon.aws.links.base_aws`¶

Module Contents¶

Classes¶

Base Helper class for constructing AWS Console Link

Attributes¶

BASE_AWS_CONSOLE_LINK

airflow.providers.amazon.aws.links.base_aws.BASE_AWS_CONSOLE_LINK = https://console.{aws_domain}[source]¶

class airflow.providers.amazon.aws.links.base_aws.BaseAwsLink[source]¶

Bases: airflow.models.BaseOperatorLink

Base Helper class for constructing AWS Console Link

name :ClassVar[str][source]¶

key :ClassVar[str][source]¶

format_str :ClassVar[str][source]¶

static get_aws_domain(aws_partition)[source]¶

format_link(**kwargs)[source]¶

Format AWS Service Link

Some AWS Service Link should require additional escaping in this case this method should be overridden.

get_link(operator, dttm=None, ti_key=None)[source]¶

Link to Amazon Web Services Console.

Parameters

operator -- airflow operator
ti_key (Optional[airflow.models.taskinstance.TaskInstanceKey]) -- TaskInstance ID to return link for
dttm (Optional[datetime.datetime]) -- execution date. Uses for compatibility with Airflow 2.2

Returns

link to external system

Return type

classmethod persist(context, operator, region_name, aws_partition, **kwargs)[source]¶

Store link information into XCom

Was this entry helpful?