`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, *, ti_key)[source]¶

Link to Amazon Web Services Console.

Parameters

operator (airflow.models.BaseOperator) – airflow operator
ti_key (airflow.models.taskinstance.TaskInstanceKey) – TaskInstance ID to return link for

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?