`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. Requires either the output of a

class airflow.providers.amazon.aws.links.emr.EmrClusterLink[source]¶

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]¶

class airflow.providers.amazon.aws.links.emr.EmrLogsLink[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_link(**kwargs)[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 to look it up.

Was this entry helpful?