`airflow.providers.google.cloud.links.dataproc`¶

This module contains Google Dataproc links.

Module Contents¶

`DataprocLink`	Helper class for constructing Dataproc resource link
`DataprocListLink`	Helper class for constructing list of Dataproc resources link

`DATAPROC_BASE_LINK`
`DATAPROC_JOB_LOG_LINK`
`DATAPROC_CLUSTER_LINK`
`DATAPROC_WORKFLOW_TEMPLATE_LINK`
`DATAPROC_WORKFLOW_LINK`
`DATAPROC_BATCH_LINK`
`DATAPROC_BATCHES_LINK`

airflow.providers.google.cloud.links.dataproc.DATAPROC_JOB_LOG_LINK[source]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_CLUSTER_LINK[source]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_WORKFLOW_TEMPLATE_LINK[source]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_WORKFLOW_LINK[source]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_BATCHES_LINK[source]¶

class airflow.providers.google.cloud.links.dataproc.DataprocLink[source]¶

Bases: airflow.models.BaseOperatorLink

Helper class for constructing Dataproc resource link

static persist(context, task_instance, url, resource)[source]¶

get_link(operator, *, ti_key)[source]¶

Link to external system.

Note: The old signature of this function was (self, operator, dttm: datetime). That is still supported at runtime but is deprecated.

Parameters

operator (airflow.models.BaseOperator) – The Airflow operator object this link is associated to.
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – TaskInstance ID to return link for.

Returns

link to external system

Return type

str

class airflow.providers.google.cloud.links.dataproc.DataprocListLink[source]¶