airflow.providers.amazon.aws.links.emr

Module Contents

Classes

EmrClusterLink

Helper class for constructing AWS EMR Cluster Link.

EmrLogsLink

Helper class for constructing AWS EMR Logs Link.

Functions

get_log_uri(*[, cluster, emr_client, job_flow_id])

Retrieves the S3 URI to the EMR Job logs.

Bases: airflow.providers.amazon.aws.links.base_aws.BaseAwsLink

Helper class for constructing AWS EMR Cluster Link.

name = 'EMR Cluster'[source]
key = 'emr_cluster'[source]
format_str[source]

Bases: airflow.providers.amazon.aws.links.base_aws.BaseAwsLink

Helper class for constructing AWS EMR Logs Link.

name = 'EMR Cluster Logs'[source]
key = 'emr_logs'[source]
format_str[source]

Format AWS Service Link.

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

airflow.providers.amazon.aws.links.emr.get_log_uri(*, cluster=None, emr_client=None, job_flow_id=None)[source]

Retrieves the S3 URI to the EMR Job logs.

Requires either the output of a describe_cluster call or both an EMR Client and a job_flow_id..

Was this entry helpful?