`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_BASE_LINK = https://console.cloud.google.com/dataproc[source]¶

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(self, operator, dttm=None, ti_key=None)[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 operator
ti_key (Optional[airflow.models.taskinstance.TaskInstanceKey]) -- TaskInstance ID to return link for

Returns

link to external system

Return type

str

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